| | |
|---|
| | | try: |
|---|
| | | val = pipe_strategy.recv() |
|---|
| | | if val: |
|---|
| | | if type(val) == bytes: |
|---|
| | | val = val.decode("utf-8") |
|---|
| | | val = json.loads(val) |
|---|
| | | _type = val["type"] |
|---|
| | | cls.process_command_thread_pool.submit(lambda: cls.process_command(_type, None, val)) |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | | logger_local_huaxin_trade_debug.exception(e) |
|---|
| | | async_log_util.exception(logger_local_huaxin_trade_debug, e) |
|---|
| | | logging.exception(e) |
|---|
| | | except Exception as e: |
|---|
| | | logger_local_huaxin_trade_debug.exception(e) |
|---|
| | | async_log_util.exception(logger_local_huaxin_trade_debug, e) |
|---|
| | | |
|---|
| | | # 维护连接数的稳定 |
|---|
| | | def run(self, blocking=True): |
|---|
