作者FFALAN (Alan)
看板Python
標題[問題] multiprocess + sleep 問題
時間Tue Jan 30 23:34:34 2018
from time import sleep
from multiprocessing import Process, Lock
def time_delay(d):
sleep(d)
def printer(item, lock):
print(item)
lock.acquire()
print('time delay start')
time_delay(1)
print('time delay end')
lock.release()
if __name__ == '__main__':
lock = Lock()
items = ['item1', 'item2', 'item3']
for item in items:
p = Process(target=printer, args=(item, lock))
p.start()
請問各位前輩，為何輸出結果是
item1
time delay start
time delay end
item2
time delay start
time delay end
item3
time delay start
time delay end
而不是
item1
item2
item3
time delay start
time delay end
time delay start
time delay end
time delay start
time delay end
明明print item的時候還沒被Lock住阿...
而且他是先執行time_delay才開始print item...
請問是我哪裡誤會了lock的用法?
謝謝各位!
--
※ 發信站: 批踢踢實業坊(ptt.cc), 來自: 1.169.214.73
※ 文章網址: https://webptt.com/m.aspx?n=bbs/Python/M.1517326477.A.A90.html
※ 編輯: FFALAN (1.169.214.73), 01/30/2018 23:36:38
1F：→ djshen: 版本 平台 01/31 00:27
2F：→ uranusjr: Multiprocess 可能的狀況太多了, 這樣根本無法解 02/01 17:29
3F：→ uranusjr: Lock 本身就是很不可靠的東西, 我唯一的建議是不要用 02/01 17:30
4F：→ FFALAN: 2.7/windows 02/02 00:44
5F：推 cphe: multiprocess這個情況跑出來的順序不一定是可預期的 02/02 20:33
6F：→ cphe: 你這段code我直接拿來跑，結果就和你的不一樣 02/02 20:33
7F：→ cphe: lock的目的是確保acquire和release之間同時只會有一人執行 02/02 20:34
8F：→ a110482: lock.acquire() 不是指"上鎖" 應該要理解成，lock是一把 02/04 03:03
9F：→ a110482: 大家共用的鎖．而lock.acquire()要解釋成：如果lock沒被 02/04 03:05
10F：→ a110482: 上鎖，那我(這一條線程)就把鎖鎖上．然後接著執行後面的 02/04 03:06
11F：→ a110482: code 若有其他線程先鎖住了，那我就在這行待命，直到鎖 02/04 03:07
12F：→ a110482: 解開 02/04 03:08