python 多线程 锁

参考:《Python cookbook》12章

启动和停止线程

start 启动线程;

is_alive 判断是否已经结束;

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

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

终止线程:

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

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

《python 多线程 锁》

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().

    原文作者:sunbinqiang
    原文地址: https://www.jianshu.com/p/fd7f79084e83
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞