From ecd0e6d017fedb1271d0f50f547b3fdd6e025da6 Mon Sep 17 00:00:00 2001 From: Mike Bayer Date: Sat, 30 May 2009 01:11:12 +0000 Subject: [PATCH] use util.threading --- lib/sqlalchemy/queue.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/lib/sqlalchemy/queue.py b/lib/sqlalchemy/queue.py index 848c272b70..2aaeea9d0f 100644 --- a/lib/sqlalchemy/queue.py +++ b/lib/sqlalchemy/queue.py @@ -9,7 +9,7 @@ condition.""" from collections import deque from time import time as _time - +from sqlalchemy.util import threading __all__ = ['Empty', 'Full', 'Queue'] @@ -30,10 +30,6 @@ class Queue: If `maxsize` is <= 0, the queue size is infinite. """ - try: - import threading - except ImportError: - import dummy_threading as threading self._init(maxsize) # mutex must be held whenever the queue is mutating. All methods # that acquire mutex must release it before returning. mutex -- 2.47.3