Searched refs:ThreadedWorkQueue (Results 1 – 3 of 3) sorted by relevance
12 wq = threaded_work_queue.ThreadedWorkQueue(num_threads=1)16 wq = threaded_work_queue.ThreadedWorkQueue(num_threads=4)
9 class ThreadedWorkQueue(object): class
48 self._wq = threaded_work_queue.ThreadedWorkQueue(num_threads=jobs)