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: in Bb_queue, only signal condition on push if queue was empty

Browse source
This commit is contained in:
Simon Cruanes 2023-08-23 20:43:44 -04:00
parent 18d5bad2a9
commit 0f670c47d3
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/bb_queue.ml
View file

@ -29,8 +29,9 @@ let push (self : _ t) x : unit =
Mutex.unlock self.mutex; Mutex.unlock self.mutex;
raise Closed raise Closed
) else ( ) else (
let was_empty = Queue.is_empty self.q in
Queue.push x self.q; Queue.push x self.q;
Condition.signal self.cond; if was_empty then Condition.broadcast self.cond;
Mutex.unlock self.mutex Mutex.unlock self.mutex
) )
@ -79,8 +80,9 @@ let try_push (self : _ t) x : bool =
raise Closed raise Closed
); );
let was_empty = Queue.is_empty self.q in
Queue.push x self.q; Queue.push x self.q;
Condition.signal self.cond; if was_empty then Condition.broadcast self.cond;
Mutex.unlock self.mutex; Mutex.unlock self.mutex;
true true
) else ) else