From 75143a1b8f5e70734e799349326a1050e15062b7 Mon Sep 17 00:00:00 2001 From: Denis Bilenko Date: Mon, 22 Jun 2009 15:57:01 +0700 Subject: [PATCH] fix pools to use new Queue class --- eventlet/pools.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/eventlet/pools.py b/eventlet/pools.py index 77d8b49..eb36583 100644 --- a/eventlet/pools.py +++ b/eventlet/pools.py @@ -95,7 +95,7 @@ class Pool(object): self.current_size -= 1 return - if self.channel.sem.balance < 0: + if self.waiting(): self.channel.send(item) else: if self.order_as_stack: @@ -116,10 +116,8 @@ class Pool(object): def waiting(self): """Return the number of routines waiting for a pool item. """ - if self.channel.sem.balance < 0: - return -self.channel.sem.balance - return 0 - + return self.channel.waiting() + def create(self): """Generate a new pool item """