多進程：主要運行multiprocessing模塊

import os,timeimport sysfrom multiprocessing import Processclass MyProcess(Process):  """docstring for MyProcess"""  def __init__(self, arg, callback):    super(MyProcess, self).__init__()    self.arg = arg    self.callback = callback  def run(self):    self.callback(self.arg)def test(arg):  print("子進程{}開始>>> pid={}".format(arg,os.getpid()))  for i in range(1,5):    sys.stdout.write("子進程{}運行中{}/r".format(arg,i))    sys.stdout.flush()    time.sleep(1)def main():  print("主進程開始>>> pid={}".format(os.getpid()))  myp=MyProcess(1,test)  myp.start()  myp2=MyProcess(2,test)  myp2.start()  myp.join()  myp2.join()  print("主進程終止")if __name__ == '__main__':  main()

線程池：主要運用了未來模塊！下面例子，第一個是正常，第二第線程池，第三個用運行了2個線程池，會排隊

from concurrent.futures import ThreadPoolExecutorimport timedef sayhello(a):  print("hello: "+a)  time.sleep(2)def main():  seed=["a","b","c"]  start1=time.time()  for each in seed:    sayhello(each)  end1=time.time()  print("time1: "+str(end1-start1))  start2=time.time()  with ThreadPoolExecutor(3) as executor:    for each in seed:      executor.submit(sayhello,each)  end2=time.time()  print("time2: "+str(end2-start2))  start3=time.time()  with ThreadPoolExecutor(2) as executor1:    executor1.map(sayhello,seed)  end3=time.time()  print("time3: "+str(end3-start3))if __name__ == '__main__':  main()

總結(jié)

以上所述是小編給大家介紹的python多進程使用及線程池的使用方法代碼詳解，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復(fù)大家的。在此也非常感謝大家對武林站長站網(wǎng)站的支持！