@@ -306,7 +306,7 @@ generated thunks.
306
306
macro par (exs... )
307
307
opts = exs[1 : end - 1 ]
308
308
ex = exs[end ]
309
- _par (ex; lazy= true , opts= opts)
309
+ return esc ( _par (ex; lazy= true , opts= opts) )
310
310
end
311
311
312
312
"""
@@ -348,7 +348,7 @@ also passes along any options in an `Options` struct. For example,
348
348
macro spawn (exs... )
349
349
opts = exs[1 : end - 1 ]
350
350
ex = exs[end ]
351
- _par (ex; lazy= false , opts= opts)
351
+ return esc ( _par (ex; lazy= false , opts= opts) )
352
352
end
353
353
354
354
struct ExpandedBroadcast{F} end
@@ -372,17 +372,16 @@ function _par(ex::Expr; lazy=true, recur=true, opts=())
372
372
args = ex. args[2 : end ]
373
373
kwargs = Expr (:parameters )
374
374
end
375
- opts = esc .(opts)
376
375
args_ex = _par .(args; lazy= lazy, recur= false )
377
376
kwargs_ex = _par .(kwargs. args; lazy= lazy, recur= false )
378
377
if lazy
379
- return :(Dagger. delayed ($ ( esc (f)) , $ Options (;$ (opts... )))($ (args_ex... ); $ (kwargs_ex... )))
378
+ return :(Dagger. delayed ($ f , $ Options (;$ (opts... )))($ (args_ex... ); $ (kwargs_ex... )))
380
379
else
381
- sync_var = esc ( Base. sync_varname)
380
+ sync_var = Base. sync_varname
382
381
@gensym result
383
382
return quote
384
383
let args = ($ (args_ex... ),)
385
- $ result = $ spawn ($ ( esc (f)) , $ Options (;$ (opts... )), args... ; $ (kwargs_ex... ))
384
+ $ result = $ spawn ($ f , $ Options (;$ (opts... )), args... ; $ (kwargs_ex... ))
386
385
if $ (Expr (:islocal , sync_var))
387
386
put! ($ sync_var, schedule (Task (()-> wait ($ result))))
388
387
end
@@ -394,7 +393,6 @@ function _par(ex::Expr; lazy=true, recur=true, opts=())
394
393
return Expr (ex. head, _par .(ex. args, lazy= lazy, recur= recur, opts= opts)... )
395
394
end
396
395
end
397
- _par (ex:: Symbol ; kwargs... ) = esc (ex)
398
396
_par (ex; kwargs... ) = ex
399
397
400
398
"""
0 commit comments