zoukankan      html  css  js  c++  java
  • python 进程锁

    作用:异步修改数据时,会造成数据安全问题,子进程分别进入文件/数据库,修改数据

    """
    过程:
    1.导入Lock模块
    2.创建Lock对象
    3.Lock对象做为要锁的进程的参数
    4.lock.acquire()
    5.lock.release()
    """
    from multiprocessing import Process
    from multiprocessing import Lock
    
    
    def for_fun(lock):
        lock.acquire()
        pass
        lock.release()
    
    
    if __name__ == '__main__':
        lock = Lock()
        p = Process(target=for_fun(), args=(lock, ))
    # 查看、购买电影票
    # 购买要设置锁,涉及到数据的修改
    import time
    import json
    from multiprocessing import Process
    from multiprocessing import Lock
    
    
    def read(name):
        with open(file='ticket', mode='r', encoding='utf-8') as f:
            ret = json.load(f)['ticket']
            print('%s查询,还剩%s张票' % (name, ret))
    
    
    def buy(name, lock):
        lock.acquire()      # 拿钥匙
        with open(file='ticket', mode='r', encoding='utf-8') as f:
            ret = json.load(f)
            time.sleep(0.1)
        if ret['ticket'] > 0:
            ret['ticket'] -= 1
    
            print('%s购买成功' % name)
        else:
            print('%s购买失败' % name)
        time.sleep(0.1)
        with open(file='ticket', mode='w', encoding='utf-8') as f:
            json.dump(ret, f)
            time.sleep(0.1)
        lock.release()      # 还钥匙
    
    
    if __name__ == '__main__':
        lock = Lock()
       
        for i in range(1, 3):
            p = Process(target=read, args=('tom%s' % i, ))
            p.start()
            p = Process(target=buy, args=('tom%s' % i, lock))
            p.start()
    """
    结果:
    tom1查询,还剩1张票
    tom2查询,还剩1张票
    tom2购买成功
    tom1购买失败
    """
  • 相关阅读:
    Flume入门与进阶
    git如何忽略已经加入版本控制的文件
    Redis常用命令
    如何在宝塔面板上添加创建一个定时任务
    PHP代码篇(九)PHP接口开发如何使用JWT进行验证身份
    七. Go并发编程--sync.Once
    六. Go并发编程--WaitGroup
    5. Go 并发编程--sync/atomic
    4. Go并发编程--Mutex/RWMutex
    docker内服务访问宿主机服务
  • 原文地址:https://www.cnblogs.com/wt7018/p/11048674.html
Copyright © 2011-2022 走看看