Searched refs:dequeue_thread (Results 1 – 5 of 5) sorted by relevance
211 dequeue_thread = self.checkedThread(target=dequeue)213 dequeue_thread.start()215 dequeue_thread.join()733 for dequeue_thread in dequeue_threads:734 dequeue_thread.start()737 for dequeue_thread in dequeue_threads:738 dequeue_thread.join()761 dequeue_thread = self.checkedThread(target=dequeue)762 dequeue_thread.start()778 dequeue_thread.join()[all …]
850 dequeue_thread = self.checkedThread(target=dequeue)852 dequeue_thread.start()854 dequeue_thread.join()1001 dequeue_thread = self.checkedThread(target=dequeue)1002 dequeue_thread.start()1007 dequeue_thread.join()1024 dequeue_thread = self.checkedThread(target=dequeue)1025 dequeue_thread.start()1030 dequeue_thread.join()1052 dequeue_thread = self.checkedThread(target=dequeue)[all …]
180 dequeue_thread = self.checkedThread(target=dequeue)182 dequeue_thread.start()184 dequeue_thread.join()549 dequeue_thread = self.checkedThread(target=dequeue)551 dequeue_thread.start()553 dequeue_thread.join()576 dequeue_thread = self.checkedThread(target=dequeue)578 dequeue_thread.start()580 dequeue_thread.join()682 dequeue_thread = self.checkedThread(target=blocking_dequeue)[all …]
150 dequeue_thread = self.checkedThread(target=dequeue)152 dequeue_thread.start()154 dequeue_thread.join()
836 Thread* dequeue_thread = new Thread("dequeue_thread", Thread::Priority::NORMAL); in RegisterDequeueAndDelete() local837 Handler* dequeue_handler = new Handler(dequeue_thread); in RegisterDequeueAndDelete()