Searched refs:worker_semaphore (Results 1 – 1 of 1) sorted by relevance
| /external/chromium-trace/catapult/third_party/gsutil/gslib/ |
| D | command.py | 1434 worker_semaphore = threading.BoundedSemaphore(thread_count)
1442 thread_count, self.logger, worker_semaphore,
1448 worker_semaphore.acquire()
1458 worker_semaphore.release()
1642 def __init__(self, thread_count, logger, worker_semaphore, argument
1648 self.task_queue, logger, worker_semaphore=worker_semaphore,
1668 def __init__(self, task_queue, logger, worker_semaphore=None, argument
1687 self.worker_semaphore = worker_semaphore
1725 if self.worker_semaphore:
1726 self.worker_semaphore.release()
|