pub async fn push(&self, item: T) {
        let permit = self.push_semaphore.acquire().await.unwrap();
        self.available.add();
        self.queue.push(item).ok().unwrap();
        permit.forget();
        self.pop_semaphore.add_permits(1);
    }
/// Push an item into the queue
Push an item into the queue
Push an item into the queue
pub async fn push(&self, item: T) {
        let permit = self.push_semaphore.acquire().await.unwrap();
        self.available.add();
        self.queue.push(item).ok().unwrap();
        permit.forget();
        self.pop_semaphore.add_permits(1);
    }
pub async fn push ( & self , item : T ) { let permit = self . push_semaphore . acquire ( ) . await . unwrap ( ) ; self . available . add ( ) ; self . queue . push ( item ) . ok ( ) . unwrap ( ) ; permit . forget ( ) ; self . pop_semaphore . add_permits ( 1 ) ; }
Push an item into the queue
Push an item into the queue
&self
item
T
&self
item
T