python 程序 python程序

python程序池pool

當需要建立的子程序數量不多時，可以直接利用multiprocessing中的process動態生成多個程序,但如果是上百甚至上千個目標，手動的去建立程序的工作量巨大，此時就可以用到multiprocessing模組提供的pool方法。

初始化pool是，可以指定乙個最大程序數，當有新的請求提交到pool中是，如果吃還沒有滿，那麼就會建立乙個新的程序來執行該請求。但如果池中的程序數已經達到指定的最大值，那麼該請求就會等待，直到池中有程序結束，才會用之前的程序來執行新的任務。

import multiprocessing

import time

import os

import random

def test1(msg):

t_start = time.time()

print("%s開始執行，程序號為%d" % (msg, os.getpid()))

time.sleep(random.random() * 2)

t_stop = time.time()

print("%s執行完成，耗時%.2f" % (msg, t_stop - t_start))

if __name__ == "__main__":

po = multiprocessing.pool(3)

for i in range(0, 10):

# 每次迴圈將會用空閒出來的子程序去呼叫目標

print("-----start-----")

po.close() # 關閉程序池，關閉後po不再接收新的請求

po.join() # 等待po中所有子程序執行完成，必須放在close語句之後

print("-----end-----")

multiprocessing.pool常用函式解析：

close()：關閉pool，使其不再接受新的任務；

terminate()：不管任務是否完成，立即終止；

join()：主程序阻塞，等待子程序的退出，必須在close或terminate之後使用；

python程序池中的queue

如果要使用pool建立程序，就需要使用multiprocessing.manager()中的queue(),而不是multiprocessing.queue(),否則會得到一條如下的錯誤資訊：

runtimeerror:queue objects should only be shared between processes through inheritance.

下面的例項演示了程序池中的程序如何通訊：

import os

import multiprocessing

import time

def write(q):

print("write啟動(%s)，父程序為(%s)" % (os.getpid(), os.getppid()))

for i in "python":

q.put(i)

def read(q):

print("read啟動(%s)，父程序為(%s)" % (os.getpid(), os.getppid()))

for i in range(q.qsize()):

print("read從queue獲取到訊息：%s" % q.get(true))

if __name__ == "__main__":

print("(%s) start" % os.getpid())

q = multiprocessing.manager().queue()

po = multiprocessing.pool()

time.sleep(2)

po.close()

po.join()

print("(%s) end" % os.getpid())

python 程序 python程序

python子程序 Python實戰之子程序

python程序和執行緒 Python中的程序和執行緒

Python併發程式設計之程序（殭屍程序孤兒程序）

python 程序 python程序

python子程序 Python實戰之子程序

python程序和執行緒 Python中的程序和執行緒

Python併發程式設計之程序（殭屍程序 孤兒程序）

相關推薦

Python併發程式設計之程序（殭屍程序孤兒程序）