From c8d9f6ea560fdaf4e08005c6f7d8d666b76c82b0 Mon Sep 17 00:00:00 2001 From: Denis Bilenko Date: Fri, 24 Apr 2009 18:15:39 +0700 Subject: [PATCH] proc: optionally accept queue as a parameter in waitall() function --- eventlet/proc.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/eventlet/proc.py b/eventlet/proc.py index 724888b..4c00eea 100644 --- a/eventlet/proc.py +++ b/eventlet/proc.py @@ -168,8 +168,9 @@ class LinkToCallable(Link): self.listener(source) -def waitall(lst, trap_errors=False): - queue = coros.queue() +def waitall(lst, trap_errors=False, queue=None): + if queue is None: + queue = coros.queue() index = -1 for (index, linkable) in enumerate(lst): linkable.link(decorate_send(queue, index))