def reset_pool(self):
closefn = self._close_function()
while True:
if not self.pool.qsize():
break
try:
conn = self.pool.get()
closefn(conn)
self.pool.task_done()
except Queue.Empty:
break
with self._lock:
self.outstanding = 0
评论列表
文章目录