diff options
| author | Sebastian Thiel <byronimo@gmail.com> | 2010-06-08 19:25:33 +0200 |
|---|---|---|
| committer | Sebastian Thiel <byronimo@gmail.com> | 2010-06-08 19:25:33 +0200 |
| commit | 772b95631916223e472989b43f3a31f61e237f31 (patch) | |
| tree | cac3b488a05502b15532b07bb3848e0fdb2df339 /lib/git/async/channel.py | |
| parent | e5c0002d069382db1768349bf0c5ff40aafbf140 (diff) | |
| download | gitpython-772b95631916223e472989b43f3a31f61e237f31.tar.gz | |
workerthread: adjusted to use a blocking queue, it will receive termination events only with its queue, with boosts performance into brigt green levels
Diffstat (limited to 'lib/git/async/channel.py')
| -rw-r--r-- | lib/git/async/channel.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/lib/git/async/channel.py b/lib/git/async/channel.py index 5c52b1dc..c05f7383 100644 --- a/lib/git/async/channel.py +++ b/lib/git/async/channel.py @@ -60,7 +60,6 @@ class WChannel(Channel): # let the queue handle the 'closed' attribute, we write much more often # to an open channel than to a closed one, saving a few cycles try: - print "putting item", item, id(self._queue.queue) self._queue.put(item, block, timeout) except ReadOnly: raise IOError("Cannot write to a closed channel") @@ -76,7 +75,7 @@ class WChannel(Channel): an error""" # yes, close it a little too early, better than having anyone put # additional items - print "closing channel", self + # print "closing channel", self self._closed = True self._queue.set_writable(False) |