zoukankan      html  css  js  c++  java
  • 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() 
    以后遇到更好的例子再做补充。
  • 相关阅读:
    vue router路由懒加载
    vue router动态路由
    vue router路由跳转
    vue router-link属性
    vue router mode
    vue router
    vuecli脚手架
    R读取大文件速度太慢?来试试能提速两千倍的fread
    基于RAINBOW的单倍型全基因组关联分析(haplotype-based GWAS)教程
    今日Vlog:Jmeter中那些循环
  • 原文地址:https://www.cnblogs.com/progor/p/8439711.html
Copyright © 2011-2022 走看看