Skip to content

Instantly share code, notes, and snippets.

@DrChainsaw
Created September 7, 2021 20:25
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save DrChainsaw/10eb9d7491b491500f052414565ceedd to your computer and use it in GitHub Desktop.
Save DrChainsaw/10eb9d7491b491500f052414565ceedd to your computer and use it in GitHub Desktop.
Dagger sleepmyid
julia> @everywhere function sleepmyid()
sleep(2)
myid()
end
julia> ts = delayed(vcat)([delayed(sleepmyid)() for i in 1:10]...)
Thunk[22](vcat, (Thunk[12](sleepmyid, ()), Thunk[13](sleepmyid, ()), Thunk[14](sleepmyid, ()), Thunk[15](sleepmyid, ()), Thunk[16](sleepmyid, ()), Thunk[17](sleepmyid, ()), Thunk[18](sleepmyid, ()), Thunk[19](sleepmyid, ()), Thunk[20](sleepmyid, ()), Thunk[21](sleepmyid, ())))
julia> collect(ts)
From worker 2: ┌ Debug: (2) sleepmyid (12) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (13) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (14) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (15) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (16) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (17) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (18) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (19) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (12) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (13) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (14) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (15) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (16) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (17) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (18) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (19) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (13) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (14) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (15) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (16) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (17) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (18) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (19) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (14) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (15) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (16) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (17) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (18) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (19) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (15) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (16) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (17) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (18) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (19) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (16) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (17) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (18) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (19) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (17) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (18) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (19) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (18) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (19) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (20) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (19) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (20) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (21) Waiting for free Dagger.ThreadProc: 1000000000 | 1000000000/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:932
From worker 2: ┌ Debug: (2) sleepmyid (20) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) sleepmyid (21) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) sleepmyid (21) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
From worker 2: ┌ Debug: (2) vcat (22) Using available Dagger.ThreadProc(2, 1): 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:937
From worker 2: ┌ Debug: (2) vcat (22) Releasing Dagger.ThreadProc: 1000000000 | 0/1000000000
From worker 2: └ @ Dagger.Sch E:\Programs\julia\.julia\packages\Dagger\akmDx\src\sch\Sch.jl:977
10-element Vector{Int64}:
2
2
2
2
2
2
2
2
2
2
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment