simon/moonpool
1
0
Fork 0
mirror of https://github.com/c-cube/moonpool.git synced 2025-12-06 03:05:30 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat worker_loop: always use reschedule in await

Browse source 
it's better than continuing right now because it will potentially
reschedule on the correct runner.
This commit is contained in:
Simon Cruanes 2025-07-09 22:05:36 -04:00
parent 796c4f6f31
commit a24bd7472d
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/core/worker_loop_.ml
View file

@ -83,8 +83,8 @@ let with_handler (type st) ~(ops : st ops) (self : st) : (unit -> unit) -> unit
let fiber = get_current_fiber_exn () in let fiber = get_current_fiber_exn () in
(* when triggers is signaled, reschedule task *) (* when triggers is signaled, reschedule task *)
if not (Picos.Fiber.try_suspend fiber trigger fiber k reschedule) then if not (Picos.Fiber.try_suspend fiber trigger fiber k reschedule) then
(* trigger was already signaled, run task now *) (* trigger was already signaled, reschedule task now *)
Picos.Fiber.resume fiber k) reschedule trigger fiber k)
| Picos.Computation.Cancel_after _r -> | Picos.Computation.Cancel_after _r ->
Some Some
(fun k -> (fun k ->