绑核运行

Administrator

2024-11-19 355e831e82f17d53b9cc05406504e53403ae44b7

绑核运行

 l2_test.py

@@ -1,5 +1,6 @@
import multiprocessing
import time
import psutil

from huaxin_client import l2_client_test, l1_subscript_codes_manager
from log_module.log import logger_local_huaxin_l2_upload
@@ -18,8 +19,10 @@
    for i in range(cpu_count):
        process = multiprocessing.Process(target=l2_client_test.run,
                                          args=(codes[i * page_size:(i + 1) * page_size], big_order_queue,))
        process.start()

        process.start()
        # 绑核运行
        psutil.Process(process.pid).cpu_affinity([i])
    while True:
        try:
            data = big_order_queue.get()