def __init__(self):
self.pool = Queue.Queue(maxsize=0)
self.outstanding = 0
self._lock = threading.Lock()
def handler(signum, frame):
self.reset_pool()
signal.signal(signal.SIGINT, handler)
signal.signal(signal.SIGTERM, handler)
评论列表
文章目录