From c188a4c5062c94ef415e1bb8242d2941d99ade80 Mon Sep 17 00:00:00 2001 From: Johnny Robeson Date: Mon, 20 Jun 2016 00:27:54 -0400 Subject: [PATCH] use queue from six.moves --- beets/util/pipeline.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/beets/util/pipeline.py b/beets/util/pipeline.py index b5f777336..648d11b70 100644 --- a/beets/util/pipeline.py +++ b/beets/util/pipeline.py @@ -34,7 +34,7 @@ in place of any single coroutine. from __future__ import division, absolute_import, print_function -import Queue +from six.moves import queue from threading import Thread, Lock import sys @@ -75,13 +75,13 @@ def _invalidate_queue(q, val=None, sync=True): q.mutex.release() -class CountedQueue(Queue.Queue): +class CountedQueue(queue.Queue): """A queue that keeps track of the number of threads that are still feeding into it. The queue is poisoned when all threads are finished with the queue. """ def __init__(self, maxsize=0): - Queue.Queue.__init__(self, maxsize) + queue.Queue.__init__(self, maxsize) self.nthreads = 0 self.poisoned = False