kosipov/parall_prog_110mko
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Обновить lec1/simple_run.py

Browse Source
This commit is contained in:
kosipov
2026-10-17 08:45:04 +02:00
parent 4e975729fc
commit 7c2ef43090
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lec1/simple_run.py
+8 -9
View File
@@ -3,12 +3,11 @@ from bench import bench
from mc_parallel import estimate_pi_parallel from mc_parallel import estimate_pi_parallel
N_PER_WORKER = 5_000_000 # объём работы на одного исполнителя N_PER_WORKER = 5_000_000 # объём работы на одного исполнителя
if __name__ == "__main__": if __name__ == "__main__":
print(" p N T(p), с E_weak") print(" p N T(p), с E_weak")
for p in [1, 2, 4, 6, 8, 10]: for p in [1, 2, 4, 6, 8, 10]:
n = N_PER_WORKER * p # задача растёт вместе с числом процессов n = N_PER_WORKER * p # задача растёт вместе с числом процессов
with ProcessPoolExecutor(max_workers=p) as pool: with ProcessPoolExecutor(max_workers=p) as pool:
tp, _, _ = bench(estimate_pi_parallel, n, pool, p) tp, _, _ = bench(estimate_pi_parallel, n, pool, p)
9 if p == 1:
if p == 1: t_base = tp
t_base = tp print(f"{p:2d} {n:10_d} {tp:7.2f} {t_base / tp:6.2f}")
print(f"{p:2d} {n:10_d} {tp:7.2f} {t_base / tp:6.2f}")