# coding=utf-8 ''' Created on 2016年6月17日 @author: Pro1 ''' import queue ''' 封装队列 ''' class BlockQueue(): def __init__(self, maxSize=0): self.queue = queue.Queue(maxsize=maxSize) self.closed = False def getQueue(self): return self.queue def close(self): self.closed = True def isClose(self): return self.closed