Reference counting in CpuPool and Inner about futures-rs HOT 5 CLOSED

    // in new()
    let pool = CpuPool {
        inner: Arc::new(Inner {
            queue: MsQueue::new(),
            cnt: AtomicUsize::new(1), // <- starts with 1
            size: size
        }),
    };

// ...

impl Drop for CpuPool {
    fn drop(&mut self) {
        if self.inner.cnt.fetch_sub(1, Ordering::Relaxed) != 0 {
            // when only one instance is left, and it's being destroyed, fetch_sub returns 1, cnt becomes 0,
            // but this always returns here, because fetch_sub retruned 1, and not 0
        }
        // this never gets called
        for _ in 0..self.inner.size {
            self.inner.queue.push(Message::Close);
        }
    }
}