1 Star 1 Fork 1

孙连城/MultiProcess

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
test_max_core.py 1.11 KB
一键复制 编辑 原始数据 按行查看 历史
孙连城 提交于 2020-01-19 13:44 . sick somehow, i simplified lines again
import multiprocessing
import time
from speedtest import foo
import matplotlib.pyplot as plt
from functools import wraps
def count_time(func):
@wraps(func)
def wrapper(t):
a = time.time()
func(t)
b = time.time()
return b - a
return wrapper
@count_time
def multi_core(core_num):
[multiprocessing.Process(target=foo).start() for _ in range(core_num)]
[process.join() for process in multiprocessing.active_children()]
@count_time
def normal(time_):
var_a = 1
while var_a <= time_:
foo()
var_a += 1
def collect_data(max) -> dict:
data = {}
for func in [multi_core, normal]:
data[func.__name__] = []
[data[func.__name__].append(func(i)) for i in range(1, max + 1, 5)]
return data
def main(num: int):
data = collect_data(num)
[plt.plot(list(range(1, num + 1, 5)), list(data[i]),ls='-.' ,label=i) for i in data.keys()]
plt.legend()
plt.title('Time to complete unit work')
plt.xlabel('process NUM')
plt.ylabel('second spend')
plt.tight_layout()
plt.show()
if __name__ == '__main__':
main(20)
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Python
1
https://gitee.com/MasonSun/MultiProcess.git
git@gitee.com:MasonSun/MultiProcess.git
MasonSun
MultiProcess
MultiProcess
master

搜索帮助