python Queue一般用于哪些方面，这段代码大概是什么流程意思，谢谢

Question

from ccnet.sync_client import SyncClient
import Queue

class ClientPool(object):
    """ccnet client pool."""

    def __init__(self, conf_dir, pool_size=5):
        """
        :param conf_dir: the ccnet configuration directory
        :param pool_size:
        """
        self.conf_dir = conf_dir
        self.pool_size = pool_size
        self._pool = Queue.Queue(pool_size)

    def _create_client(self):
        client = SyncClient(self.conf_dir)
        client.req_ids = {}
        client.connect_daemon()

        return client

    def get_client(self):
        try:
            client = self._pool.get(False)
        except:
            client = self._create_client()
        return client

    def return_client(self, client):
        try:
            self._pool.put(client, False)
        except Queue.Full:
            pass

class SyncClient(Client):
    '''sync mode client'''
    def __init__(self, config_dir):
        Client.__init__(self, config_dir)
        self._req_id = _REQ_ID_START
        self.mq_req_id = -1

    def disconnect_daemon(self):
        if self.is_connected():
            try:
                self._connfd.close()
            except:
                pass

    def read_response(self):
        packet = read_packet(self._connfd)
        if packet.header.ptype != CCNET_MSG_RESPONSE:
            raise RuntimeError('Invalid Response')

        code, code_msg, content = parse_response(packet.body)

        return Response(code, code_msg, content)

    def send_cmd(self, cmd):
        req_id = self.get_request_id()
        self.send_request(req_id, 'receive-cmd')
        resp = self.read_response()
        if resp.code != '200':
            raise RuntimeError('Failed to send-cmd: %s %s' % (resp.code, resp.code_msg))

        cmd += '\000'
        self.send_update(req_id, '200', '', cmd)

        resp = self.read_response()
        if resp.code != '200':
            raise RuntimeError('Failed to send-cmd: %s %s' % (resp.code, resp.code_msg))

        self.send_update(req_id, SC_PROC_DONE, SS_PROC_DONE, '')

    def prepare_recv_message(self, msg_type):
        request = 'mq-server %s' % msg_type
        req_id = self.get_request_id()
        self.send_request(req_id, request)

        resp = self.read_response()
        if resp.code != '200':
            raise RuntimeError('bad response: %s %s' % (resp.code, resp.code_msg))

    def receive_message(self):
        resp = self.read_response()
        # the message from ccnet daemon has the trailing null byte included
        msg = message_from_string(resp.content[:-1])
        return msg

    def prepare_send_message(self):
        request = 'mq-server'
        mq_req_id = self.get_request_id()
        self.send_request(mq_req_id, request)
        resp = self.read_response()
        if resp.code != '200':
            raise RuntimeError('bad response: %s %s' % (resp.code, resp.code_msg))
        self.mq_req_id = mq_req_id

    def send_message(self, msg_type, content):
        if self.mq_req_id == -1:
            self.prepare_send_message()

        msg = gen_inner_message_string(self.peer_id, msg_type, content)
        self.send_update(self.mq_req_id, "300", '', msg)
        resp = self.read_response()
        if resp.code != '200':
            self.mq_req_id = -1
            raise RuntimeError('bad response: %s %s' % (resp.code, resp.code_msg))

    def register_service_sync(self, service, group):
        '''Mainly used by a program to register a dummy service to ensure only
        single instance of that program is running

        '''
        cmd = 'register-service %s %s' % (service, group)
        self.send_cmd(cmd)

Answer 1

Queue 저는 이 데이터 구조를 거의 사용하지 않지만 Python의 문서를 확인했습니다:

큐 모듈은 다중 생산자, 다중 소비자 큐를 구현합니다. 이는 여러 스레드 간에 정보를 안전하게 교환해야 하는 경우 스레드 프로그래밍에 특히 유용합니다. 이 모듈의 Queue 클래스는 필요한 모든 잠금 의미를 구현합니다. Python의 스레드 지원 여부에 따라 다릅니다. 스레딩 모듈을 참조하세요.

문서에는 이것이 thread-safe 큐이므로 다중 스레드 프로그래밍에서 흔히 발생하는 다중 생산자와 다중 소비자가 있는 경쟁 환경에서 사용할 수 있다고 명시되어 있습니다.

이것이 Queue에 대한 나의 이해입니다. 이제 질문의 코드에 대해 이야기해 보겠습니다. 이 코드는 客户端的池라는 것을 이름에서 분명히 알 수 있습니다. > 메서드를 사용하면 get_client() 클라이언트가 반환됩니다. SyncClient을 호출하여 다시 변경하세요. 그렇지 않으면 여기에 대량의 클라이언트가 생성됩니다. 클라이언트가 너무 많으면 문제가 될 수 있습니다. return_client(client)

그 정도인데 질문자가 이해했는지 모르겠네요.

Answer 2

큐는 스레드로부터 안전한 큐입니다. @yylucifer가 이를 더 명확하게 설명했습니다. 이는 실제로 재사용 가능한 클라이언트 풀입니다. redis-py의 풀 디자인을 보면 알 수 있습니다. blockconnectionpool one은 기본적으로 같은 생각입니다.