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() 
    以后遇到更好的例子再做补充。
  • 相关阅读:
    arcgis10.2 sde配置
    创建只读账号oracle
    oracle 的tnsnames.ora,listener.ora
    gp工具的许可
    复制整个数据库
    显示二维表格的位置计算
    windows文件名格式的中文+数字混合字符串排序
    supergridcontrol记录,分页
    outlook-由于本机的限制,该操作已被取消。请与系统管理员联系。
    自定义单元格式
  • 原文地址:https://www.cnblogs.com/progor/p/8439711.html
Copyright © 2011-2022 走看看