文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

python 锁机制

2023-01-31 07:23

关注

wKiom1e7lSzSPeudAAAMUzyp5Ds993.png-wh_50锁(LOCK)

当有两个或跟多个线程或进程需要操作一个变量或进程时,会出现意想不到的结果,这是因为线程或进程时迸发进行的,对同意变量或文件操作时,会出现同时对其操作,从到导致逻辑错误。

#!/bin/usr/env python
#coding:utf-8
import multiprocessing
import time
class multF(multiprocessing.Process):
    """docstring for multF"""
    def __init__(self,filename,proname,stime):
        multiprocessing.Process.__init__(self)
        self.filename = filename
        self.proname  = proname
        self.stime    = stime
    def run(self):
        with open(self.filename,'a') as f:
            for x in xrange(1,5):
                f.write("进程编号:"+str(self.proname)+"---"+str(x)+'\n')
                time.sleep(self.stime)
        f.close()
        print u"文件写入完成."
def main():
    filename = './test.txt'
    t1 = multF(filename,'01',2)
    t2 = multF(filename,'02',1)
    t3 = multF(filename,'03',2)
    t1.start()
    t2.start()
    t3.start()
    t1.join()
    t2.join()
    t3.join()
    print u"结束"   
if __name__ == '__main__':
    main()


为解决以上问题我们需要引入锁。

锁有两种状态:被锁(locked)和没有被锁(unlocked)。拥有acquire()和release()两种方法,并且遵循以下的规则:

如果一个锁的状态是unlocked,调用acquire()方法改变它的状态为locked;
如果一个锁的状态是locked,acquire()将会阻塞,直到另一个线程或进程调用release()方法释放它;
如果一个锁的状态是unlocked,调用release()会抛出RuntimeError异常;
如果一个锁的状态是locked,调用release()方法改变它的状态Wieunlocked。


解决上面两个进程或线程同时写一个文件的问题的方法就是:我们给写文件的类的构造器中传入一个锁(lock),使用这个锁来保护文件操作,实现在给定的时间只有一个线程写文件。

#!/bin/usr/env python
#coding:utf-8
import multiprocessing
import time
class multF(multiprocessing.Process):
    """docstring for multF"""
    def __init__(self,filename,proname,stime,lock):
        multiprocessing.Process.__init__(self)
        self.filename = filename
        self.proname  = proname
        self.stime    = stime
        self.lock       = lock
    def run(self):
        with open(self.filename,'a') as f:
            self.lock.acquire()
            for x in xrange(1,5):
                f.write("进程编号:"+str(self.proname)+"---"+str(x)+'\n')
                time.sleep(self.stime)
        f.close()
        self.lock.release()
        print u"文件写入完成."
def main():
    filename = './test2.txt'
    lock = multiprocessing.Lock()
    t1 = multF(filename,'01',2, lock)
    t2 = multF(filename,'02',1,lock)
    t3 = multF(filename,'03',2,lock)
    t1.start()
    t2.start()
    t3.start()
    t1.join()
    t2.join()
    t3.join()
    print u"结束"   
if __name__ == '__main__':
    main()




阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯