python 多线程 锁

作者: sunbinqiang | 来源:发表于2016-06-28 13:23 被阅读233次

    参考:《Python cookbook》12章

    启动和停止线程

    start 启动线程;

    is_alive 判断是否已经结束;

    join 请求连接某个线程, 等待该线程结束,才退出join函数;

    daemon参数, 守护线程,该线程无法被连接,主线程结束后自动销毁。(2.7不适用)

    终止线程:

    需要自己构建终止操作, 一般在while循环中添加标识符来判断是否需要停止线程。

    一个demo, 当terminate()后,线程即退出

    Event

    event 可以实现线程间的通信, 比如这样的情况:线程t1必须在线程t2执行完以后再执行(例如,数据库操作的线程必须等到数据库连接上以后再执行),这时用event可以达到这样的效果

    多线程模式下,操作同一数据的时候,需要进行同步控制,否则容易对数据造成破坏。

    threading模块提供的Lock类,可以实现某一时刻只有一个线程操作某个数据对象:

    ```

    #创建锁

    mutex = threading.Lock()

    #锁定

    mutex.acquire([timeout])

    #释放

    mutex.release()

    ```

    其中acquire函数的timeout参数,是指在timeout指定的时间后会通过返回值判断,从而进行一些其他操作。

    死锁: 

    在上述mutex.acquire()以后,还没有release以前,又进行acquire操作,这时就会出现死锁的情况。在代码逻辑比较复杂的项目中,某一些函数里面很容易出现这样的情况,引发死锁。

    threading模块还有另外一个类:Rlock,可重入锁,不会发生死锁的情况,但是要保证一次acquire对应一次release。

    另外,可以用语句: with mutex: 代替 mutex.acquire()和mutex.release().

    相关文章

      网友评论

        本文标题:python 多线程 锁

        本文链接:https://www.haomeiwen.com/subject/vohadttx.html