andy/c_soft
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

编译时使用cpu核心个进程

Browse Source
This commit is contained in:
andy
2025-06-28 10:18:18 +08:00
parent 5bf41295cf
commit b91c6b908d
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
make.py
View File

@@ -7,7 +7,7 @@ import os
import sys import sys
import time import time
import dataclasses 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_lambda_fun import search_lambda
from create_signal_fun import moc_file_create 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)) 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()): if(cmd_queue.empty()):
return return
process_list = [] process_list = []
@@ -143,7 +143,7 @@ def run_cmd_queue(cmd_queue:Queue,cpu_num:int=4):
p.start() p.start()
process_list.append(p) process_list.append(p)
for i in process_list: for i in process_list:
p.join() i.join()
while not return_list.empty(): while not return_list.empty():
i=return_list.get() i=return_list.get()
if(not i[1]): if(not i[1]):
@@ -173,7 +173,7 @@ def build_depend(src:list):
CmdQueue.put(cmd_item_t(cmd,f"更新 {dst}")) CmdQueue.put(cmd_item_t(cmd,f"更新 {dst}"))
dst_list.append(dst) dst_list.append(dst)
run_cmd_queue(CmdQueue) 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}")) CmdQueue.put(cmd_item_t(cmd,f"编译 {dst}"))
dst_list.append(dst) dst_list.append(dst)
run_cmd_queue(CmdQueue) run_cmd_queue(CmdQueue)
check_exists(dst_list) # check_exists(dst_list)
# 生成可执行文件 # 生成可执行文件

10
make_riscv.py
View File

@@ -4,7 +4,7 @@ import sys
import time import time
import shutil import shutil
import dataclasses 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)) 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()): if(cmd_queue.empty()):
return return
process_list = [] process_list = []
@@ -158,7 +158,7 @@ def run_cmd_queue(cmd_queue:Queue,cpu_num:int=4):
p.start() p.start()
process_list.append(p) process_list.append(p)
for i in process_list: for i in process_list:
p.join() i.join()
while not return_list.empty(): while not return_list.empty():
i=return_list.get() i=return_list.get()
if(not i[1]): if(not i[1]):
@@ -186,7 +186,7 @@ def build_depend(src:list):
CmdQueue.put(cmd_item_t(cmd,f"更新 {dst}")) CmdQueue.put(cmd_item_t(cmd,f"更新 {dst}"))
dst_list.append(dst) dst_list.append(dst)
run_cmd_queue(CmdQueue) run_cmd_queue(CmdQueue)
check_exists(dst_list) # check_exists(dst_list)
# 生成中间文件 # 生成中间文件
def build_object(src:list): def build_object(src:list):
@@ -210,7 +210,7 @@ def build_object(src:list):
CmdQueue.put(cmd_item_t(cmd,f"编译 {dst}")) CmdQueue.put(cmd_item_t(cmd,f"编译 {dst}"))
dst_list.append(dst) dst_list.append(dst)
run_cmd_queue(CmdQueue) run_cmd_queue(CmdQueue)
check_exists(dst_list) # check_exists(dst_list)
# 生成可执行文件 # 生成可执行文件