From: Mike Bayer Date: Sat, 30 May 2009 01:11:12 +0000 (+0000) Subject: use util.threading X-Git-Tag: rel_0_6_6~199 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=ecd0e6d017fedb1271d0f50f547b3fdd6e025da6;p=thirdparty%2Fsqlalchemy%2Fsqlalchemy.git use util.threading --- 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