From 0ed52455b76458e935ca3fe368a4637000769691 Mon Sep 17 00:00:00 2001 From: Benjamin Peterson Date: Sat, 21 Mar 2009 17:36:10 +0000 Subject: [PATCH] port the queue change r70405 --- Lib/queue.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/Lib/queue.py b/Lib/queue.py index 450f845d443..f051f1c89f2 100644 --- a/Lib/queue.py +++ b/Lib/queue.py @@ -1,6 +1,10 @@ """A multi-producer, multi-consumer queue.""" from time import time as _time +try: + import threading as _threading +except ImportError: + import dummy_threading as _threading from collections import deque import heapq @@ -20,26 +24,22 @@ class Queue: If maxsize is <= 0, the queue size is infinite. """ def __init__(self, maxsize=0): - try: - import threading - except ImportError: - import dummy_threading as threading self.maxsize = maxsize self._init(maxsize) # mutex must be held whenever the queue is mutating. All methods # that acquire mutex must release it before returning. mutex # is shared between the three conditions, so acquiring and # releasing the conditions also acquires and releases mutex. - self.mutex = threading.Lock() + self.mutex = _threading.Lock() # Notify not_empty whenever an item is added to the queue; a # thread waiting to get is notified then. - self.not_empty = threading.Condition(self.mutex) + self.not_empty = _threading.Condition(self.mutex) # Notify not_full whenever an item is removed from the queue; # a thread waiting to put is notified then. - self.not_full = threading.Condition(self.mutex) + self.not_full = _threading.Condition(self.mutex) # Notify all_tasks_done whenever the number of unfinished tasks # drops to zero; thread waiting to join() is notified to resume - self.all_tasks_done = threading.Condition(self.mutex) + self.all_tasks_done = _threading.Condition(self.mutex) self.unfinished_tasks = 0 def task_done(self):