| 536 | static GLOBAL_ID: std::sync::atomic::AtomicU64 = std::sync::atomic::AtomicU64::new(0); |
| 537 | |
| 538 | pub struct GlobalQueue<D> { |
| 539 | new: Vec<std::sync::Mutex<Vec<(u64, Arc<D>)>>>, |
| 540 | } |
| 541 | |
| 542 | impl<D> GlobalQueue<D> { |
| 543 | pub fn init(workers: usize) -> Self { |
nothing calls this directly
no outgoing calls
no test coverage detected