Searched refs:shared_queue (Results 1 – 1 of 1) sorted by relevance
545 let mut shared_queue = self.decommit_queue.lock().unwrap(); in merge_or_flush() localVariable546 shared_queue.append(&mut local_queue); in merge_or_flush()550 if shared_queue.raw_len() >= self.decommit_batch_size { in merge_or_flush()551 self.flush_decommit_queue(shared_queue); in merge_or_flush()