重构响应处理模块,将message_queue替换为response_pool
🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <noreply@anthropic.com>pull/31/head
parent
d69bdfabbc
commit
c365f2277f
4
main.py
4
main.py
|
|
@ -7,7 +7,9 @@ from src.recv_handler import recv_handler
|
|||
from src.send_handler import send_handler
|
||||
from src.config import global_config
|
||||
from src.mmc_com_layer import mmc_start_com, mmc_stop_com, router
|
||||
from src.message_queue import message_queue, put_response, check_timeout_response
|
||||
from src.response_pool import put_response, check_timeout_response
|
||||
|
||||
message_queue = asyncio.Queue()
|
||||
|
||||
|
||||
async def message_recv(server_connection: Server.ServerConnection):
|
||||
|
|
|
|||
|
|
@ -28,7 +28,7 @@ from .utils import (
|
|||
get_stranger_info,
|
||||
get_message_detail,
|
||||
)
|
||||
from .message_queue import get_response
|
||||
from .response_pool import get_response
|
||||
|
||||
|
||||
class RecvHandler:
|
||||
|
|
|
|||
|
|
@ -6,8 +6,6 @@ from .logger import logger
|
|||
|
||||
response_dict: Dict = {}
|
||||
response_time_dict: Dict = {}
|
||||
message_queue = asyncio.Queue()
|
||||
|
||||
|
||||
async def get_response(request_id: str) -> dict:
|
||||
retry_count = 0
|
||||
|
|
@ -12,7 +12,7 @@ from typing import Dict, Any, Tuple
|
|||
|
||||
from . import CommandType
|
||||
from .config import global_config
|
||||
from .message_queue import get_response
|
||||
from .response_pool import get_response
|
||||
from .logger import logger
|
||||
from .utils import get_image_format, convert_image_to_gif
|
||||
|
||||
|
|
|
|||
|
|
@ -3,7 +3,7 @@ import json
|
|||
import base64
|
||||
import uuid
|
||||
from .logger import logger
|
||||
from .message_queue import get_response
|
||||
from .response_pool import get_response
|
||||
|
||||
import urllib3
|
||||
import ssl
|
||||
|
|
|
|||
Loading…
Reference in New Issue