diff options
| author | Sebastian Thiel <byronimo@gmail.com> | 2010-06-08 16:47:48 +0200 |
|---|---|---|
| committer | Sebastian Thiel <byronimo@gmail.com> | 2010-06-08 16:47:48 +0200 |
| commit | 619c11787742ce00a0ee8f841cec075897873c79 (patch) | |
| tree | 7cfcc718c049b26abedf280bebb6c65a6d6f619c /lib/git/async/pool.py | |
| parent | 53152a824f5186452504f0b68306d10ebebee416 (diff) | |
| download | gitpython-619c11787742ce00a0ee8f841cec075897873c79.tar.gz | |
Its getting better already - intermediate commit before further chaning the task class
Diffstat (limited to 'lib/git/async/pool.py')
| -rw-r--r-- | lib/git/async/pool.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/lib/git/async/pool.py b/lib/git/async/pool.py index d6b5711d..cf1c2199 100644 --- a/lib/git/async/pool.py +++ b/lib/git/async/pool.py @@ -80,8 +80,8 @@ class RPoolChannel(RChannel): # * make no assumptions if there are multiple consumers # * have_enough = False - if count > 0: - have_enough = self._task.scheduled_item_count() >= count or self._wc._queue.qsize() >= count + #if count > 0: + # have_enough = self._task.scheduled_item_count() >= count or self._wc._queue.qsize() >= count # END ########## prepare ############################## @@ -319,6 +319,7 @@ class Pool(object): def _del_task_if_orphaned(self, task): """Check the task, and delete it if it is orphaned""" + # 1 as its stored on the task, 1 for the getrefcount call if sys.getrefcount(task._out_wc) < 3: self.del_task(task) #} END internal @@ -403,7 +404,7 @@ class Pool(object): if not task in self._tasks.nodes: return self # END early abort - + print "deleting ", id(task) # the task we are currently deleting could also be processed by # a thread right now. We don't care about it as its taking care about # its write channel itself, and sends everything it can to it. |