connection_pool.py 文件源码

def put(self, conn_holder, replace=False):
        """Put back the conn_holder (returned by get()) in queue.

        Args:
            conn_holder: connection holder returned by get()
            replace: whether to create a new replacement for this connection.

        """
        assert self._queue.qsize() < self.pool_size
        assert conn_holder.pool_name == self.pool_name

        if replace:
            self._close_conn(conn_holder)

        self._queue.put_nowait(conn_holder)