| | |
|---|
| | | channels = channel_list[index:index + channel_count] |
|---|
| | | index += channel_count |
|---|
| | | # 订阅信号队列, 数据回调队列（回调频次小的数据通过这种回调） |
|---|
| | | sub_single_queue, data_callback_queue = multiprocessing.Queue(), multiprocessing.Queue() |
|---|
| | | sub_single_queue, data_callback_queue = multiprocessing.Queue(maxsize=1024), multiprocessing.Queue(maxsize=1024) |
|---|
| | | sub_single_queue_list.append(sub_single_queue) |
|---|
| | | data_callback_queue_list.append(data_callback_queue) |
|---|
| | | l2_process = multiprocessing.Process(target=l2_client_v2.run, |
|---|
| | |
|---|
| | | |
|---|
| | | # 测试L2单独进程 |
|---|
| | | |
|---|
| | | if True: |
|---|
| | | if constant.IS_L2_NEW: |
|---|
| | | __create_l2_subscript() |
|---|
| | | else: |
|---|
| | | # 将L2的进程改为线程执行 |
|---|
