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

tweal to WS pool

Browse source
This commit is contained in:
Simon Cruanes 2023-10-27 12:26:50 -04:00
parent 08722691e8
commit c044fb8fc9
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/ws_pool.ml
View file

@ -98,7 +98,7 @@ exception Got_task of task
type around_task = AT_pair : (t -> 'a) * (t -> 'a -> unit) -> around_task type around_task = AT_pair : (t -> 'a) * (t -> 'a -> unit) -> around_task
(** How many times in a row do we try to do work-stealing? *) (** How many times in a row do we try to do work-stealing? *)
let steal_attempt_max_retry = 3 let steal_attempt_max_retry = 2
(** Main loop for a worker thread. *) (** Main loop for a worker thread. *)
let worker_thread_ (self : state) (runner : t) (w : worker_state) ~on_exn let worker_thread_ (self : state) (runner : t) (w : worker_state) ~on_exn
@ -157,9 +157,8 @@ let worker_thread_ (self : state) (runner : t) (w : worker_state) ~on_exn
| Some task -> | Some task ->
run_task task; run_task task;
raise_notrace Exit raise_notrace Exit
| None -> | None -> incr unsuccessful_steal_attempts
incr unsuccessful_steal_attempts; (* Domain_.relax () *)
Domain_.relax ()
done; done;
false false
with Exit -> true with Exit -> true