From 3feb11ef2987dd825890936662701b18574a4973 Mon Sep 17 00:00:00 2001 From: Ed Page Date: Tue, 16 Mar 2010 21:52:35 -0500 Subject: [PATCH] Minor bug fix in async pool --- src/util/go_utils.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/util/go_utils.py b/src/util/go_utils.py index ef6cb72..b3682ba 100644 --- a/src/util/go_utils.py +++ b/src/util/go_utils.py @@ -131,7 +131,7 @@ class Timeout(object): return False -__QUEUE_EMPTY = object() +_QUEUE_EMPTY = object() class AsyncPool(object): @@ -151,7 +151,7 @@ class AsyncPool(object): self.__isRunning = False for _ in algorithms.itr_available(self.__workQueue): pass # eat up queue to cut down dumb work - self.__workQueue.put(__QUEUE_EMPTY) + self.__workQueue.put(_QUEUE_EMPTY) def add_task(self, func, args, kwds, on_success, on_error): task = func, args, kwds, on_success, on_error @@ -172,7 +172,7 @@ class AsyncPool(object): def __consume_queue(self): while True: task = self.__workQueue.get() - if task is __QUEUE_EMPTY: + if task is _QUEUE_EMPTY: break func, args, kwds, on_success, on_error = task -- 1.7.9.5