亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Python多進(jìn)程編程技術(shù)實(shí)例分析

系統(tǒng) 1578 0

本文以實(shí)例形式分析了Python多進(jìn)程編程技術(shù),有助于進(jìn)一步Python程序設(shè)計(jì)技巧。分享給大家供大家參考。具體分析如下:

一般來說,由于Python的線程有些限制,例如多線程不能充分利用多核CPU等問題,因此在Python中我們更傾向使用多進(jìn)程。但在做不阻塞的異步UI等場景,我們也會(huì)使用多線程。本篇文章主要探討Python多進(jìn)程的問題。

Python在2.6引入了多進(jìn)程的機(jī)制,并提供了豐富的組件及api以方便編寫并發(fā)應(yīng)用。multiprocessing包的組件Process, Queue, Pipe, Lock等組件提供了與多線程類似的功能。使用這些組件,可以方便地編寫多進(jìn)程并發(fā)程序。

Process

Process的使用有點(diǎn)像java.lang.Thread,但Thread是線程。start方法用以啟動(dòng)某個(gè)進(jìn)程。一個(gè)簡單的示例:

            
from multiprocessing import Process
import os
import time
def sleeper(name, seconds):
  print "Process ID# %s" % (os.getpid())
  print "Parent Process ID# %s" % (os.getppid())
  print "%s will sleep for %s seconds" % (name, seconds)
  time.sleep(seconds)

if __name__ == "__main__":
  child_proc = Process(target=sleeper, args=('bob', 5))
  child_proc.start()
  print "in parent process after child process start"
  print "parent process abount to join child process"
  child_proc.join()
  print "in parent process after child process join"
  print "the parent's parent process: %s" % (os.getppid())


          

實(shí)例化一個(gè)Process必須要指定target和args。target是新的進(jìn)程的入口方法,可以認(rèn)為是main方法。args是該方法的參數(shù)列表。啟動(dòng)進(jìn)程類似于啟動(dòng)Thread,必須要調(diào)用start方法。也可以繼承Process,覆蓋run方法,在run方法中實(shí)現(xiàn)該進(jìn)程的邏輯。調(diào)用join方法會(huì)阻塞當(dāng)前調(diào)用進(jìn)程,直到被調(diào)用進(jìn)程運(yùn)行結(jié)束。
手工終止一個(gè)進(jìn)程可以調(diào)用terminate方法,在UNIX系統(tǒng)中,該方法會(huì)發(fā)送SIGTERM信號(hào)量,而在windows系統(tǒng)中,會(huì)借助TerminateProcess方法。需要注意的是,exit處理邏輯并不會(huì)被執(zhí)行,該進(jìn)程的子進(jìn)程不會(huì)被終止,他們只會(huì)變成孤兒進(jìn)程。

Queue

Queue是多進(jìn)程安全的隊(duì)列,可以使用Queue實(shí)現(xiàn)多進(jìn)程之間的數(shù)據(jù)傳遞。put方法用以插入數(shù)據(jù)到隊(duì)列中,put方法還有兩個(gè)可選參數(shù):blocked和timeout。如果blocked為True(默認(rèn)值),并且timeout為正值,該方法會(huì)阻塞timeout指定的時(shí)間,直到該隊(duì)列有剩余的空間。如果超時(shí),會(huì)拋出Queue.Full異常。如果blocked為False,但該Queue已滿,會(huì)立即拋出Queue.Full異常。

get方法可以從隊(duì)列讀取并且刪除一個(gè)元素。同樣,get方法有兩個(gè)可選參數(shù):blocked和timeout。如果blocked為True(默認(rèn)值),并且timeout為正值,那么在等待時(shí)間內(nèi)沒有取到任何元素,會(huì)拋出Queue.Empty異常。如果blocked為False,有兩種情況存在,如果Queue有一個(gè)值可用,則立即返回該值,否則,如果隊(duì)列為空,則立即拋出Queue.Empty異常。Queue的一段示例代碼:

            
from multiprocessing import Process, Queue
def offer(queue):
  queue.put("Hello World")
def test(queue, num):
  queue.put("Hello World: " + str(num))
if __name__ == '__main__':
  q = Queue()
  p1 = Process(target=test, args=(q, 1))
  p1.start()
  p = Process(target=offer, args=(q,))
  p.start()
  p2 = Process(target=test, args=(q, 2))
  p2.start()
  p2 = Process(target=test, args=(q, 3))
  p2.start()
  print q.get()
  print q.get()
  print q.get()
  print q.get()
  print q.close()


          

輸出:

Hello World: 1
Hello World
Hello World: 2
None

Pipes

Pipe方法返回(conn1, conn2)代表一個(gè)管道的兩個(gè)端。Pipe方法有duplex參數(shù),如果duplex參數(shù)為True(默認(rèn)值),那么這個(gè)管道是全雙工模式,也就是說conn1和conn2均可收發(fā)。duplex為False,conn1只負(fù)責(zé)接受消息,conn2只負(fù)責(zé)發(fā)送消息。

send和recv方法分別是發(fā)送和接受消息的方法。例如,在全雙工模式下,可以調(diào)用conn1.send發(fā)送消息,conn1.recv接收消息。如果沒有消息可接收,recv方法會(huì)一直阻塞。如果管道已經(jīng)被關(guān)閉,那么recv方法會(huì)拋出EOFError。

            
from multiprocessing import Process, Pipe

def send(conn):
  conn.send("Hello World")
  conn.close()
if __name__ == '__main__':
  parent_conn, child_conn = Pipe()
  p = Process(target=send, args=(child_conn,))
  p.start()
  print parent_conn.recv()


          

同步

multiprocessing包提供了Condition, Event, Lock, RLock, Semaphore等組件可用于同步。下面是使用Lock的一個(gè)示例:

            
from multiprocessing import Process, Lock
def l(lock, num):
  lock.acquire() 
  print "Hello Num: %s" % (num)
  lock.release()
if __name__ == '__main__':
  lock = Lock()
for num in range(20):
  Process(target=l, args=(lock, num)).start()


          

總結(jié)

以上是Python multiprocessing庫的簡單介紹和實(shí)例,熟悉Java多線程開發(fā)的同學(xué)是不是覺得很熟悉,和java的Concurrency API很像,不過javaConcurrency是處理多線程的而已,我們可以直接按照以前Java多線程的經(jīng)驗(yàn)用這些API。

感興趣的朋友可以測試運(yùn)行本文實(shí)例以加深理解。相信本文所述對大家Python程序設(shè)計(jì)的學(xué)習(xí)有一定的借鑒價(jià)值。


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號(hào)聯(lián)系: 360901061

您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長非常感激您!手機(jī)微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會(huì)非常 感謝您的哦!!!

發(fā)表我的評(píng)論
最新評(píng)論 總共0條評(píng)論
主站蜘蛛池模板: 玖玖成人网 | 久热re国产手机在线观看 | 亚洲国产婷婷香蕉久久久久久 | 亚洲国产精品成人久久 | 五月天中文字幕 | 一级午夜视频 | 国产欧美日韩高清专区ho | 国产系列欧美系列日韩系列在线 | 亚洲欧美日韩中文字幕在线一区 | www四虎在线高清 | 日本在线观看不卡免费视频 | 97碰公开在线观看免费视频 | 亚洲欧美中文字幕高清在线一 | 青草青青在线视频 | 免费不卡中文字幕在线 | 国产成人高清精品免费观看 | 精品日本久久久久久久久久 | 亚洲一区中文字幕 | 久久精品香蕉视频 | 国产综合色在线视频区色吧图片 | 橘子视频在线观看 | 欧美一级毛片久久精品 | 这里只有精品久久 | 最新中文字幕日本 | 狠狠干天天爽 | 欧美一级一极性活片免费观看 | 九九视频在线观看6 | 四虎影院免费在线播放 | 免费一级毛片在线播放放视频 | 男女羞羞网站 | 色综七七久久成人影 | 日本免费久久 | 中文乱码字幕午夜无线观看 | 亚洲第一页在线播放 | 亚洲乱码中文字幕 | 欧美毛片免费看 | 91蝌蚪在线播放 | 国产成人18黄网站免费 | 免费一级成人免费观看 | 白蛇缘起3免费观看 | 热re99久久精品国产99热 |