python并发编程多进程 互斥锁原理解析

时间:2021-05-22

运行多进程 每个子进程的内存空间是互相隔离的 进程之间数据不能共享的

互斥锁

但是进程之间都是运行在一个操作系统上,进程之间数据不共享,但是共享同一套文件系统,所以访问同一个文件,或同一个打印终端,

是可以的,而共享带来的是竞争,竞争带来的结果就是错乱

#并发运行,效率高,但竞争同一打印终端,带来了打印错乱from multiprocessing import Processimport timedef task(name): print("%s 1" % name) time.sleep(1) print("%s 2" % name) time.sleep(1) print("%s 3" % name)if __name__ == '__main__': for i in range(3): p = Process(target=task, args=("子进程%s" % i,)) p.start()'''子进程2 1子进程0 1子进程1 1子进程2 2子进程1 2子进程0 2子进程2 3子进程1 3子进程0 3'''

如何控制,就是加锁处理。而互斥锁的意思就是互相排斥,如果把多个进程比喻为多个人,

互斥锁的工作原理就是多个人都要去争抢同一个资源:卫生间,一个人抢到卫生间后上一把锁,其他人都要等着,等到这个完成任务后释放锁,其他人才有可能有一个抢到......

所以互斥锁的原理,就是把并发改成串行,降低了效率,但保证了数据安全,不错乱

加了互斥锁就没有并发效果了 加上锁只有一个可以运行 互斥锁会把并发变成串行 效率变低了

解决:

导入模块 Lock

现在程序启动 所有进程首先会去抢锁 只有抢到锁的才能运行

等这个进程运行完了解锁后 再到其他进程继续抢锁

from multiprocessing import Process, Lockimport timedef task(name, mutex): # 加锁 mutex.acquire() print("%s 1" % name) time.sleep(1) print("%s 2" % name) time.sleep(1) print("%s 3" % name) # 把锁拆了 mutex.release()if __name__ == '__main__': # 建一个对象实例 mutex = Lock() for i in range(3): # 把锁传给子进程 让所有子进程用同一把锁 p = Process(target=task, args=("子进程%s" % i, mutex)) p.start()'''现在程序启动 所有进程首先会去抢锁 只有抢到锁的才能运行等这个进程运行完了解锁后 再到其他进程继续抢锁''''''子进程0 1子进程0 2子进程0 3子进程1 1子进程1 2子进程1 3子进程2 1子进程2 2子进程2 3'''

牺牲了效率,保证数据不错乱

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章