Limiting Queue Depth for Blocking Thread Pool

[joshleeb]

In the docs for task::spawn_blocking it says that if all the threads in the blocking thread pool are busy, then the tasks are put in a queue. And I see that the upper limit of the blocking thread pool can be configured for the runtime with Builder::max_blocking_threads.

Q. Is there a way to configure, or otherwise limit, the max depth of the queue containing tasks awaiting the blocking thread pool?

Thanks! 🙏

[Darksonn]

No, the queue is unbounded. If you need custom limits on spawn_blocking tasks, then you can use a Semaphore. See its examples for ideas. You should be able to use try_acquire to fail spawning when there are too many tasks.

[joshleeb]

Perfect, thank you! And thank you for the quick response 🎉