| | |
|---|
| | | |
|---|
| | | import zmq |
|---|
| | | |
|---|
| | | from huaxin_client import socket_util |
|---|
| | | from huaxin_client.client_network import SendResponseSkManager |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import logger_local_huaxin_trade_debug, logger_trade, logger_local_huaxin_contact_debug |
|---|
| | | |
|---|
| | |
|---|
| | | class TradeCommandManager: |
|---|
| | | trade_client_dict = {} |
|---|
| | | _instance = None |
|---|
| | | process_command_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=30) |
|---|
| | | process_command_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=20) |
|---|
| | | |
|---|
| | | def __new__(cls, *args, **kwargs): |
|---|
| | | if not cls._instance: |
|---|
