[問題] multiprocess + sleep + Lock問題

作者: FFALAN (Alan)   2018-01-30 23:34:34
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的用法?
謝謝各位!
作者: djshen (djshen)   2018-01-31 00:27:00
版本 平台
作者: uranusjr (←這人是超級笨蛋)   2018-02-01 17:29:00
Multiprocess 可能的狀況太多了, 這樣根本無法解Lock 本身就是很不可靠的東西, 我唯一的建議是不要用
作者: FFALAN (Alan)   2018-02-02 00:44:00
2.7/windows
作者: cphe (魔鬼藏在垃圾筒裡)   2018-02-02 20:33:00
multiprocess這個情況跑出來的順序不一定是可預期的你這段code我直接拿來跑,結果就和你的不一樣lock的目的是確保acquire和release之間同時只會有一人執行
作者: a110482 (研磨綠豆沙)   2018-02-04 03:03:00
lock.acquire() 不是指"上鎖" 應該要理解成,lock是一把大家共用的鎖.而lock.acquire()要解釋成:如果lock沒被上鎖,那我(這一條線程)就把鎖鎖上.然後接著執行後面的code 若有其他線程先鎖住了,那我就在這行待命,直到鎖解開
作者: ar54971   2018-03-06 03:44:00
作者: galeondx   2018-03-06 04:22:00

Links booklink

Contact Us: admin [ a t ] ucptt.com