Lines Matching defs:queue
29 let mut queue = task::spawn(DelayQueue::new()); in single_immediate_delay() localVariable
45 let mut queue = task::spawn(DelayQueue::new()); in multi_immediate_delays() localVariable
74 let mut queue = task::spawn(DelayQueue::new()); in single_short_delay() localVariable
101 let mut queue = task::spawn(DelayQueue::new()); in multi_delay_at_start() localVariable
141 let mut queue = task::spawn(DelayQueue::new()); in insert_in_past_fires_immediately() localVariable
156 let mut queue = task::spawn(DelayQueue::new()); in remove_entry() localVariable
175 let mut queue = task::spawn(DelayQueue::new()); in reset_entry() localVariable
209 let mut queue = task::spawn(DelayQueue::new()); in reset_much_later() localVariable
231 let mut queue = task::spawn(DelayQueue::new()); in reset_twice() localVariable
265 let mut queue = task::spawn(DelayQueue::new()); in repeatedly_reset_entry_inserted_as_expired() localVariable
290 let mut queue = DelayQueue::new(); in remove_expired_item() localVariable
310 let mut queue = task::spawn(DelayQueue::new()); in remove_at_timer_wheel_threshold() localVariable
338 let mut queue = task::spawn(DelayQueue::new()); in expires_before_last_insert() localVariable
364 let mut queue = task::spawn(DelayQueue::new()); in multi_reset() localVariable
401 let mut queue = task::spawn(DelayQueue::new()); in expire_first_key_when_reset_to_expire_earlier() localVariable
424 let mut queue = task::spawn(DelayQueue::new()); in expire_second_key_when_reset_to_expire_earlier() localVariable
447 let mut queue = task::spawn(DelayQueue::new()); in reset_first_expiring_item_to_expire_later() localVariable
469 let mut queue = task::spawn(DelayQueue::new()); in insert_before_first_after_poll() localVariable
495 let mut queue = task::spawn(DelayQueue::new()); in insert_after_ready_poll() localVariable
528 let mut queue = task::spawn(DelayQueue::new()); in reset_later_after_slot_starts() localVariable
568 let mut queue = task::spawn(DelayQueue::new()); in reset_inserted_expired() localVariable
590 let mut queue = task::spawn(DelayQueue::new()); in reset_earlier_after_slot_starts() localVariable
627 let mut queue = task::spawn(DelayQueue::new()); in insert_in_past_after_poll_fires_immediately() localVariable
658 let mut queue = task::spawn(DelayQueue::new()); in compact_expire_empty() localVariable
681 let mut queue = task::spawn(DelayQueue::new()); in compact_remove_empty() localVariable
701 let mut queue = task::spawn(DelayQueue::new()); in compact_remove_remapped_keys() localVariable
740 let mut queue = task::spawn(DelayQueue::new()); in compact_change_deadline() localVariable
793 let mut queue = DelayQueue::new(); in item_expiry_greater_than_wheel() localVariable
810 let mut queue = DelayQueue::new(); in remove_after_compact() localVariable
827 let mut queue = task::spawn(DelayQueue::new()); in remove_after_compact_poll() localVariable
845 let mut queue = task::spawn(DelayQueue::new()); in peek() localVariable