High-level API: Make executors unbounded in order to prevent dead locks

see helgoboss/helgobox#875
helgoboss · Jul 6, 2023 · 53b384e · 53b384e
1 parent 5d70fea
commit 53b384e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/main/high/src/local_run_loop_executor.rs b/main/high/src/local_run_loop_executor.rs
@@ -47,8 +47,8 @@ struct Task {
     task_sender: Sender<Arc<Task>>,
 }
 
-pub fn new_spawner_and_executor(capacity: usize, bulk_size: usize) -> (Spawner, RunLoopExecutor) {
-    let (task_sender, ready_queue) = crossbeam_channel::bounded(capacity);
+pub fn new_spawner_and_executor(bulk_size: usize) -> (Spawner, RunLoopExecutor) {
+    let (task_sender, ready_queue) = crossbeam_channel::unbounded();
     (
         Spawner { task_sender },
         RunLoopExecutor {

diff --git a/main/high/src/run_loop_executor.rs b/main/high/src/run_loop_executor.rs
@@ -44,8 +44,8 @@ struct Task {
     task_sender: Sender<Arc<Task>>,
 }
 
-pub fn new_spawner_and_executor(capacity: usize, bulk_size: usize) -> (Spawner, RunLoopExecutor) {
-    let (task_sender, ready_queue) = crossbeam_channel::bounded(capacity);
+pub fn new_spawner_and_executor(bulk_size: usize) -> (Spawner, RunLoopExecutor) {
+    let (task_sender, ready_queue) = crossbeam_channel::unbounded();
     (
         Spawner { task_sender },
         RunLoopExecutor {