作者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/cn.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