Lines Matching refs:thread
25 # A thread to run a function that unclogs a blocked Queue.
35 # function in the main thread a chance at actually blocking before
47 # Execute a function that blocks, and in a separate thread, a function that
61 thread = _TriggerThread(trigger_func, trigger_args)
62 thread.start()
65 # If block_func returned before our thread made the call, we failed!
66 if not thread.startedEvent.is_set():
71 threading_helper.join_thread(thread) # make sure the thread terminates
76 thread = _TriggerThread(trigger_func, trigger_args)
77 thread.start()
87 threading_helper.join_thread(thread) # make sure the thread terminates
88 if not thread.startedEvent.is_set():
89 self.fail("trigger thread ended but event never set")
168 thread = threading.Thread(target=self.worker, args=(q,))
169 thread.start()
170 threads.append(thread)
179 for thread in threads:
180 thread.join()