Searched refs:enqueue_thread (Results 1 – 5 of 5) sorted by relevance
210 enqueue_thread = self.checkedThread(target=enqueue)212 enqueue_thread.start()214 enqueue_thread.join()731 for enqueue_thread in enqueue_threads:732 enqueue_thread.start()735 for enqueue_thread in enqueue_threads:736 enqueue_thread.join()792 enqueue_thread = self.checkedThread(target=enqueue)793 enqueue_thread.start()812 enqueue_thread.join()[all …]
849 enqueue_thread = self.checkedThread(target=enqueue)851 enqueue_thread.start()853 enqueue_thread.join()1131 enqueue_thread = self.checkedThread(target=enqueue)1132 enqueue_thread.start()1143 enqueue_thread.join()1327 enqueue_thread = self.checkedThread(target=blocking_enqueue)1328 enqueue_thread.start()1342 enqueue_thread.join()1365 enqueue_thread = self.checkedThread(target=blocking_enqueue)[all …]
149 enqueue_thread = self.checkedThread(target=enqueue)151 enqueue_thread.start()153 enqueue_thread.join()
179 enqueue_thread = self.checkedThread(target=enqueue)181 enqueue_thread.start()183 enqueue_thread.join()548 enqueue_thread = self.checkedThread(target=enqueue)550 enqueue_thread.start()552 enqueue_thread.join()575 enqueue_thread = self.checkedThread(target=enqueue)577 enqueue_thread.start()579 enqueue_thread.join()
826 Thread* enqueue_thread = new Thread("enqueue_thread", Thread::Priority::NORMAL); in RegisterEnqueueAndDelete() local827 Handler* enqueue_handler = new Handler(enqueue_thread); in RegisterEnqueueAndDelete()