Skip to content

Commit 9890ba7

Browse files
committed
processor_runner: Fix race in collect proc_states
1 parent d60fd3f commit 9890ba7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: src/sch/Sch.jl

+1-1
Original file line numberDiff line numberDiff line change
@@ -1207,7 +1207,7 @@ function start_processor_runner!(istate::ProcessorInternalState, uid::UInt64, re
12071207

12081208
# Try to steal from local queues randomly
12091209
# TODO: Prioritize stealing from busiest processors
1210-
states = collect(proc_states(values, uid))
1210+
states = proc_states(all_states->collect(values(all_states)), uid)
12111211
# TODO: Try to pre-allocate this
12121212
P = randperm(length(states))
12131213
for state in getindex.(Ref(states), P)

0 commit comments

Comments
 (0)