13.1、多进程:进程锁Lock、信号量、事件


进程锁:

  • 为什么要有进程锁:假如现在有一台打印机,qq要使用打印机,word文档也要使用打印机,如果没有使用进程锁,可能会导致一些问题,比如QQ的任务打印到一半,Word插进来,于是打印出来的结果是各自一半。
  • 进程锁的创建与使用:
    • 1.导入模块,from multiprocessing import Lock
    • 2.创建锁对象:lock=Lock()
    • 3.在需要锁的地方:lock.acquire()
    • 4.在释放的地方:lock.release()
from multiprocessing import Lock,Process

def f(l,num):
l.acquire()
try:
print("printer used done",num)
finally:
l.release()
if __name__ == "__main__":
lock=Lock() for num in range(10):
Process(target=f, args=(lock,num)).start()

以后遇到更好的例子再做补充。


信号量:

  • 信号量可以限制进入的进程的数量。
  • 如何使用信号量:
    1. 创建信号量对象:信号量对象=multiprocessing.BoundedSemaphore(x),x是限制进程的数量
    2. 当有进程需要进入的时候,调用acquire()来减少信号量:信号量对象.acquire()
    3. 当有进程离开的时候,调用release()来增加信号量:信号量对象.release()

以后遇到更好的例子再做补充。


事件:

  • 如何使用事件:
    1. 创建事件对象:事件对象=multiprocessing.Event()
    2. 设置事件:事件对象.set()    判断事件是否set:事件对象.is_set(),等待事件set:事件对象.wait()
    3. 清除事件:事件对象.clear()

以后遇到更好的例子再做补充。


上一篇:玩转Android Camera开发(二):使用TextureView和SurfaceTexture预览Camera 基础拍照demo


下一篇:Linux编程---线程