Skip to content
This repository has been archived by the owner on Apr 24, 2023. It is now read-only.

Commit

Permalink
Fix the parallel watch. (#2182)
Browse files Browse the repository at this point in the history
* Fix the parallel watch.

We should be executing the runnable here, not submitting it to the executor queue.
(This function is already running within that queue)

Co-authored-by: Scott Crosby <scrosby@twosigma.com>
  • Loading branch information
scrosby and Scott Crosby authored Sep 21, 2022
1 parent 64fa485 commit 899d7c5
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ void processDeque() {
var event = deque.removeFirst();
// Mark event as dequeed so we release any backpressure.
queueSlotsLeft.release();
executor.submit(event);
event.run();
}
} finally {
lock.unlock();
Expand Down

0 comments on commit 899d7c5

Please sign in to comment.