From 355e831e82f17d53b9cc05406504e53403ae44b7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 19 十一月 2024 11:05:57 +0800
Subject: [PATCH] 绑核运行
---
l2_test.py | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/l2_test.py b/l2_test.py
index 5f91eea..1830dc3 100644
--- a/l2_test.py
+++ b/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()
--
Gitblit v1.8.0