Replies: 1 comment
-
It calls This means that if new work is spawned concurrently with going to sleep, then one of these cases happen:
In either case, the thread does not actually go to sleep if new work is spawned. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I don't understand:
If workerA fails to steal-task and puts itself in the sleeper-queue with is_last_searcher=true, then during the subsequent check for task-existence, other threads may wake up workerA. Isn't this contradictory? WorkerA ignores these wake-ups and directly calls self.park_timeout(core, None). This seems problematic!
Beta Was this translation helpful? Give feedback.
All reactions