Я хочу запускать разные исполняемые файлы на разных процессорах одновременно, поэтому я взял пример отсюда:
Есть ли способ назначить разные задания (процессы) определенному ядру в Linux с помощью Python?
и попытался запустить исполняемые файлы, однако цикл FOR ждет завершения исполняемого файла, чтобы назначить новый процесс. Есть ли способ без ожидания назначить новый процесс следующему ядру?
import os
from itertools import cycle
import multiprocessing as mp
import subprocess
def map_hack(AFF):
my_pid = os.getpid()
old_aff = os.sched_getaffinity(0)
os.sched_setaffinity(0,AFF)
return (my_pid, old_aff, os.sched_getaffinity(0))
PROCESSES = os.cpu_count()
_mycpus = cycle(os.sched_getaffinity(0))
cpus = [[next(_mycpus)] for x in range(PROCESSES)]
with mp.Pool(processes=PROCESSES) as pool:
for x in pool.map(map_hack, cpus, chunksize=1):
print("Try 2:My pid is {} and my old aff was {}, my new aff is {}".format(*x))
z = str( x[2])
z = z[:-1]
z = int( z[-1:])
print (z)
if (z == 0):
print("program waits for this executable to finish")
subprocess.run(["./exevision"])
pool.close()
pool.join()
Подробнее здесь: https://stackoverflow.com/questions/790 ... processing
Использование Python для выполнения программ на различных процессорах посредством многопроцессорной обработки. ⇐ Python
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение