From b91c6b908d67a09dcefd55cec7c478c0cc617c9d Mon Sep 17 00:00:00 2001
From: andy <1414772332@qq.com>
Date: Sat, 28 Jun 2025 10:18:18 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BC=96=E8=AF=91=E6=97=B6=E4=BD=BF=E7=94=A8cp?=
 =?UTF-8?q?u=E6=A0=B8=E5=BF=83=E4=B8=AA=E8=BF=9B=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 make.py       | 10 +++++-----
 make_riscv.py | 10 +++++-----
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/make.py b/make.py
index 2d22085..fcf2d70 100644
--- a/make.py
+++ b/make.py
@@ -7,7 +7,7 @@ import os
 import sys
 import time
 import dataclasses
-from multiprocessing import Process,Queue,Value
+from multiprocessing import Process,Queue,Value,cpu_count
 from create_lambda_fun import search_lambda
 from create_signal_fun import moc_file_create
 
@@ -132,7 +132,7 @@ def run_cmd(cmd_queue:Queue,cpu_index:int,return_list:Queue,failed_num):
   return_list.put((cpu_index,True))
 
 
-def run_cmd_queue(cmd_queue:Queue,cpu_num:int=4):
+def run_cmd_queue(cmd_queue:Queue,cpu_num:int=cpu_count()):
   if(cmd_queue.empty()):
     return
   process_list = []
@@ -143,7 +143,7 @@ def run_cmd_queue(cmd_queue:Queue,cpu_num:int=4):
     p.start()
     process_list.append(p)
   for i in process_list:
-    p.join()
+    i.join()
   while not return_list.empty():
     i=return_list.get()
     if(not i[1]):
@@ -173,7 +173,7 @@ def build_depend(src:list):
       CmdQueue.put(cmd_item_t(cmd,f"更新 {dst}"))
       dst_list.append(dst)
   run_cmd_queue(CmdQueue)
-  check_exists(dst_list)
+  # check_exists(dst_list)
 
 
 # 生成中间文件
@@ -193,7 +193,7 @@ def build_object(src:list):
         CmdQueue.put(cmd_item_t(cmd,f"编译 {dst}"))
         dst_list.append(dst)
   run_cmd_queue(CmdQueue)
-  check_exists(dst_list)
+  # check_exists(dst_list)
 
 
 # 生成可执行文件
diff --git a/make_riscv.py b/make_riscv.py
index 9cd73a1..a7d87fc 100644
--- a/make_riscv.py
+++ b/make_riscv.py
@@ -4,7 +4,7 @@ import sys
 import time
 import shutil
 import dataclasses
-from multiprocessing import Process,Queue,Value
+from multiprocessing import Process,Queue,Value,cpu_count
 
 
 
@@ -147,7 +147,7 @@ def run_cmd(cmd_queue:Queue,cpu_index:int,return_list:Queue,failed_num):
   return_list.put((cpu_index,True))
 
 
-def run_cmd_queue(cmd_queue:Queue,cpu_num:int=4):
+def run_cmd_queue(cmd_queue:Queue,cpu_num:int=cpu_count()):
   if(cmd_queue.empty()):
     return
   process_list = []
@@ -158,7 +158,7 @@ def run_cmd_queue(cmd_queue:Queue,cpu_num:int=4):
     p.start()
     process_list.append(p)
   for i in process_list:
-    p.join()
+    i.join()
   while not return_list.empty():
     i=return_list.get()
     if(not i[1]):
@@ -186,7 +186,7 @@ def build_depend(src:list):
       CmdQueue.put(cmd_item_t(cmd,f"更新 {dst}"))
       dst_list.append(dst)
   run_cmd_queue(CmdQueue)
-  check_exists(dst_list)
+  # check_exists(dst_list)
 
 # 生成中间文件
 def build_object(src:list):
@@ -210,7 +210,7 @@ def build_object(src:list):
       CmdQueue.put(cmd_item_t(cmd,f"编译 {dst}"))
       dst_list.append(dst)
   run_cmd_queue(CmdQueue)
-  check_exists(dst_list)
+  # check_exists(dst_list)
 
 
 # 生成可执行文件