Python線程處理多個bash子進程？如何使用線程和子處理模塊生成并行bash進程？當我啟動線程時，首先回答如下：如何在Python中使用線程？，bash進程按順序運行，而不是并行運行。
3 回答
繁花如伊
TA貢獻2012條經驗 獲得超12個贊
from subprocess import Popencommands = [ 'date; ls -l; sleep 1; date', 'date; sleep 5; date', 'date; df -h; sleep 3; date', 'date; hostname; sleep 2; date', 'date; uname -a; date',]# run in parallelprocesses = [Popen(cmd, shell=True) for cmd in commands]# do other things here..# wait for completionfor p in processes: p.wait()
multiprocessing.dummy.Poolmultiprocessing.Pool
from functools import partialfrom multiprocessing.dummy import Poolfrom subprocess import call
pool = Pool(2) # two concurrent commands at a timefor i, returncode in enumerate(pool.imap(partial(call, shell=True), commands)):
if returncode != 0:
print("%d command failed: %d" % (i, returncode))這個答案演示了限制并發子進程數量的各種技術。
from subprocess import Popenfrom itertools import islice max_workers = 2 # no more than 2 concurrent processesprocesses = (Popen(cmd, shell=True) for cmd in commands)running_processes = list(islice(processes, max_workers)) # start new processeswhile running_processes: for i, process in enumerate(running_processes): if process.poll() is not None: # the process has finished running_processes[i] = next(processes, None) # start new process if running_processes[i] is None: # no new processes del running_processes[i] break
os.waitpid(-1, 0)
添加回答
舉報
0/150
提交
取消