欧美三区_成人在线免费观看视频_欧美极品少妇xxxxⅹ免费视频_a级毛片免费播放_鲁一鲁中文字幕久久_亚洲一级特黄

Python多進程同步Lock、Semaphore、Event實例

系統(tǒng) 1818 0

同步的方法基本與多線程相同。

1) Lock

當多個進程需要訪問共享資源的時候,Lock可以用來避免訪問的沖突。

復(fù)制代碼 代碼如下:

import multiprocessing
import sys

def worker_with(lock, f):
??? with lock:
??????? fs = open(f,"a+")
??????? fs.write('Lock acquired via with\n')
??????? fs.close()
???????
def worker_no_with(lock, f):
??? lock.acquire()
??? try:
??????? fs = open(f,"a+")
??????? fs.write('Lock acquired directly\n')
??????? fs.close()
??? finally:
??????? lock.release()

if __name__ == "__main__":

??? f = "file.txt"
?
??? lock = multiprocessing.Lock()
??? w = multiprocessing.Process(target=worker_with, args=(lock, f))
??? nw = multiprocessing.Process(target=worker_no_with, args=(lock, f))

??? w.start()
??? nw.start()

??? w.join()
??? nw.join()

在上面的例子中,如果兩個進程沒有使用lock來同步,則他們對同一個文件的寫操作可能會出現(xiàn)混亂。

2)Semaphore

Semaphore用來控制對共享資源的訪問數(shù)量,例如池的最大連接數(shù)。

復(fù)制代碼 代碼如下:

import multiprocessing
import time

def worker(s,i):
??? s.acquire()
??? print(multiprocessing.current_process().name + " acquire")
??? time.sleep(i)
??? print(multiprocessing.current_process().name + " release")
??? s.release()

if __name__ == "__main__":
?
??? s = multiprocessing.Semaphore(2)
??? for i in range(5):
??????? p = multiprocessing.Process(target=worker, args=(s,i*2))
??????? p.start()

上面的實例中使用semaphore限制了最多有2個進程同時執(zhí)行。

3)Event

Event用來實現(xiàn)進程間同步通信。

復(fù)制代碼 代碼如下:

import multiprocessing
import time

def wait_for_event(e):
??? """Wait for the event to be set before doing anything"""
??? print ('wait_for_event: starting')
??? e.wait()
??? print ('wait_for_event: e.is_set()->' + str(e.is_set()))

def wait_for_event_timeout(e, t):
??? """Wait t seconds and then timeout"""
??? print ('wait_for_event_timeout: starting')
??? e.wait(t)
??? print ('wait_for_event_timeout: e.is_set()->' + str(e.is_set()))


if __name__ == '__main__':
??? e = multiprocessing.Event()
??? w1 = multiprocessing.Process(name='block',
???????????????????????????????? target=wait_for_event,
???????????????????????????????? args=(e,))
??? w1.start()

??? w2 = multiprocessing.Process(name='non-block',
???????????????????????????????? target=wait_for_event_timeout,
???????????????????????????????? args=(e, 2))
??? w2.start()

??? time.sleep(3)
??? e.set()
??? print ('main: event is set')
???
#the output is:
#wait_for_event_timeout: starting
#wait_for_event: starting
#wait_for_event_timeout: e.is_set()->False
#main: event is set
#wait_for_event: e.is_set()->True


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

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

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

【本文對您有幫助就好】

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

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 成人在线观看国产 | 欧美日韩一区二区三区自拍 | 成人特级毛片 | 日韩成人在线观看视频 | av色在线观看 | 久久久久成人精品亚洲国产 | 亚洲综合激情七月婷婷 | 亚洲欧美综合精品久久成人 | 国产老女人精品毛片久久 | 国产成人精品日本亚洲11 | 亚洲综合99 | 欧美精品一区二区蜜臀亚洲 | 国产精品美女久久久久久久网站 | 欧美精品久久久久久久久老牛影院 | 亚洲国产欧美在线人成aaa | 白白操在线视频 | 亚洲最黄视频 | 国产日韩精品一区 | 仇爱电视剧泰剧在线观看免费播放 | 天天射天天干 | 久久精品视频在线播放 | 国产偷国产偷亚洲高清在线 | 久草在钱 | 久久久a | 成人爽A毛片免费啪啪 | 亚洲免费黄色 | 亚洲成人免费视频在线观看 | 成人免费看黄网站无遮挡 | 亚洲男人天堂网 | 国产一级毛片在线看 | 中文字幕一区二区三区四区五区 | 99久久精品久久久久久清纯 | 久久精品国产一区二区三区不卡 | 大香伊人久久精品一区二区 | 精品自拍视频 | 亚洲视频一区二区 | 操美女在线 | 亚洲蜜桃AV色情精品成人 | 97在线碰碰观看免费高清 | 欧美一区二区在线视频 | 91麻豆精品国产91久久久更新资源速度超快 |