def reset(self):
    self.pid = os.getpid()
    self._check_lock = threading.Lock()
    self.pool = self.queue_class(self.max_connections)
    while True:
        try:
            self.pool.put_nowait(None)
        except Full:
            break
    self._connections = []
def reset(self):
    self.pid = os.getpid()
    self._check_lock = threading.Lock()
    self.pool = self.queue_class(self.max_connections)
    while True:
        try:
            self.pool.put_nowait(None)
        except Full:
            break
    self._connections = []