diff options
Diffstat (limited to 'bgproc.py')
| -rw-r--r-- | bgproc.py | 8 |
1 files changed, 4 insertions, 4 deletions
@@ -34,7 +34,7 @@ class BackgroundProcessing(object): '''Manage background processing queues.''' def __init__(self, func, numprocs=None): - self._pending_requests = 0 + self.pending = 0 self.requests = multiprocessing.Queue() self.results = multiprocessing.Queue() args = (func, self.requests, self.results) @@ -46,7 +46,7 @@ class BackgroundProcessing(object): def enqueue_request(self, request): '''Put a request into queue, to be processed by workers whenever.''' - self._pending_requests += 1 + self.pending += 1 self.requests.put((request,)) def close_requests(self): @@ -73,7 +73,7 @@ class BackgroundProcessing(object): ''' - if block and self._pending_requests == 0: + if block and self.pending == 0: return [] items = [] @@ -83,7 +83,7 @@ class BackgroundProcessing(object): except Queue.Empty: break else: - self._pending_requests -= 1 + self.pending -= 1 items.append(item) block = False return items |