Improve worker_pool worker utilization

Make use of the new dispatch_sync function in rabbitmq/rabbitmq-common#368 to block only when all workers are busy (cherry picked from commit 01270fd)
rabbitmq · May 13, 2020 · 7127195 · 7127195
1 parent 78a09ca
commit 7127195
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl
@@ -1801,7 +1801,7 @@ build_index_worker(Gatherer, State = #msstate { dir = Dir },
 enqueue_build_index_workers(Gatherer, Left, [], State) ->
     exit(normal);
 enqueue_build_index_workers(Gatherer, Left, [File|Files], State) ->
-    ok = worker_pool:submit(
+    ok = worker_pool:dispatch_sync(
            fun () ->
                    link(Gatherer),
                    ok = build_index_worker(Gatherer, State,