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

perf: await on immediately ready timer queues its task

Browse source
This commit is contained in:
Simon Cruanes 2025-05-02 10:51:46 -04:00
parent b46a048401
commit d50c227578
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 arg) ~(ops : st ops) (self : st) :
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, run 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 ->