release_concurrency

Function release_concurrency 

Source
pub fn release_concurrency<'threads, T>(
    task: &mut TaskItem<'threads, T>,
    worker_id: usize,
)
where T: Debug + Send + Sync + 'threads,
Expand description

Releases any concurrency permit if present. This step is crucial in preventing a hang if a worker forgets to release. Added explicit logs to confirm the permit is dropped.