python中多進(jìn)程并行的示例分析

小編給大家分享一下python中多進(jìn)程并行的示例分析，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

代碼：

from multiprocessing import Process
import sys, os
import time


def timetask(string):
 while True:
  print(string)

def works(func, arg, worknum):
 proc_record = []
 for i in range(worknum):
  p = Process(target = func, args = (i,))
  p.start()
  proc_record.append(p)
 for p in proc_record:
  p.join()

if __name__ == '__main__':
 arg = 5
 procs = 4
 works(timetask, arg, procs)

效果圖【未加鎖，會發(fā)現(xiàn)數(shù)字1沒出現(xiàn)，進(jìn)程間資源搶奪導(dǎo)致】：

優(yōu)化之后效果：

代碼：

from multiprocessing import Process
import sys, os
import time
from threading import Lock


def timetask(string):
 mutex.acquire()
 while True:
  print(string)
  if mutex.locked():
   mutex.release()


mutex = Lock()

def works(func, arg, worknum):
 proc_record = []
 for i in range(worknum):
  p = Process(target = func, args = (i,))
  p.start()
  proc_record.append(p)
 for p in proc_record:
  p.join()

if __name__ == '__main__':
 arg = 5
 procs = 4
 works(timetask, arg, procs)

看完了這篇文章，相信你對“python中多進(jìn)程并行的示例分析”有了一定的了解，如果想了解更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！