Skip to main content

new_run_queue

Function new_run_queue 

Source
pub fn new_run_queue() -> (RunQueueSender, RunQueueReceiver)
Expand description

Create an unbounded run work queue.

Returns (sender, receiver). The queue has no capacity bound; callers are responsible for back-pressure at the API level (e.g. per-thread run limits).