'Initialize a QueueJoinThread.
Args:
queue: The queue for this thread to join.'

def __init__(self, queue):

    threading.Thread.__init__(self)
    self.setDaemon(True)
    assert isinstance(queue, (Queue.Queue, ReQueue))
    self.queue = queue
