hydro2_async_scheduler

Function fetch_next_task

Source 
pub async fn fetch_next_task<'threads, T>(
    worker_rx: &mut Receiver<TaskItem<'threads, T>>,
    worker_id: usize,
) -> Option<TaskItem<'threads, T>>
where
    T: Debug + Send + Sync + 'threads,
Expand description

Retrieves the next TaskItem from the worker’s channel. We now log more details about whether we’re waiting, whether a task is present, etc. This can help confirm if a worker is truly idle or if a hang might be from unreceived tasks.