manage/uuspider/concurrent2/.svn/text-base/blockQueue.py.svn-base

# 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