• Home
  • Raw
  • Download

Lines Matching defs:queue

28     let mut queue = task::spawn(DelayQueue::new());  in single_immediate_delay()  localVariable
44 let mut queue = task::spawn(DelayQueue::new()); in multi_immediate_delays() localVariable
73 let mut queue = task::spawn(DelayQueue::new()); in single_short_delay() localVariable
100 let mut queue = task::spawn(DelayQueue::new()); in multi_delay_at_start() localVariable
140 let mut queue = task::spawn(DelayQueue::new()); in insert_in_past_fires_immediately() localVariable
155 let mut queue = task::spawn(DelayQueue::new()); in remove_entry() localVariable
174 let mut queue = task::spawn(DelayQueue::new()); in reset_entry() localVariable
208 let mut queue = task::spawn(DelayQueue::new()); in reset_much_later() localVariable
230 let mut queue = task::spawn(DelayQueue::new()); in reset_twice() localVariable
260 let mut queue = task::spawn(DelayQueue::new()); in repeatedly_reset_entry_inserted_as_expired() localVariable
285 let mut queue = DelayQueue::new(); in remove_expired_item() localVariable
305 let mut queue = task::spawn(DelayQueue::new()); in remove_at_timer_wheel_threshold() localVariable
333 let mut queue = task::spawn(DelayQueue::new()); in expires_before_last_insert() localVariable
359 let mut queue = task::spawn(DelayQueue::new()); in multi_reset() localVariable
396 let mut queue = task::spawn(DelayQueue::new()); in expire_first_key_when_reset_to_expire_earlier() localVariable
419 let mut queue = task::spawn(DelayQueue::new()); in expire_second_key_when_reset_to_expire_earlier() localVariable
442 let mut queue = task::spawn(DelayQueue::new()); in reset_first_expiring_item_to_expire_later() localVariable
464 let mut queue = task::spawn(DelayQueue::new()); in insert_before_first_after_poll() localVariable
490 let mut queue = task::spawn(DelayQueue::new()); in insert_after_ready_poll() localVariable
523 let mut queue = task::spawn(DelayQueue::new()); in reset_later_after_slot_starts() localVariable
559 let mut queue = task::spawn(DelayQueue::new()); in reset_inserted_expired() localVariable
581 let mut queue = task::spawn(DelayQueue::new()); in reset_earlier_after_slot_starts() localVariable
618 let mut queue = task::spawn(DelayQueue::new()); in insert_in_past_after_poll_fires_immediately() localVariable
649 let mut queue = task::spawn(DelayQueue::new()); in compact_expire_empty() localVariable
672 let mut queue = task::spawn(DelayQueue::new()); in compact_remove_empty() localVariable
692 let mut queue = task::spawn(DelayQueue::new()); in compact_remove_remapped_keys() localVariable
731 let mut queue = task::spawn(DelayQueue::new()); in compact_change_deadline() localVariable
785 let mut queue = DelayQueue::new(); in remove_after_compact() localVariable
802 let mut queue = task::spawn(DelayQueue::new()); in remove_after_compact_poll() localVariable