Python多线程同步学习
2011-09-16 11:54
295 查看
多个执行线程经常要共享数据,如果仅仅读取共享数据还好,但是如果多个线程要修改共享数据的话就可能出现无法预料的结果。同步“锁”机制锁对象用threading.RLock类创建
mylock = threading.RLock()如何使用锁来同步线程呢?线程可以使用锁的acquire() (获得)方法,这样锁就进入“locked”状态。每次只有一个线程可以获得锁。如果当另一个线程试图获得这个锁的时候,就会被系统变为“blocked”状态,直到那个拥有锁的线程调用锁的release() (释放)方法,这样锁就会进入“unlocked”状态。“blocked”状态的线程就会收到一个通知,并有权利获得锁。如果多个线程处于“blocked”状态,所有线程都会先解除“blocked”状态,然后系统选择一个线程来获得锁,其他的线程继续沉默(“blocked”)。
import threadingmylock = threading.RLock()class mythread(threading.Thread)...def run(self ...):... #此处 不可以 放置修改共享数据的代码mylock.acquire()... #此处 可以 放置修改共享数据的代码mylock.release()... #此处 不可以 放置修改共享数据的代码我们把修改共享数据的代码称为“临界区”,必须将所有“临界区”都封闭在同一锁对象的acquire()和release()方法调用之间。使用条件变量锁只能提供最基本的同步级别。有时需要更复杂的线程同步,例如只在发生某些事件时才访问一个临界区(例如当某个数值改变时)。这就要使用“条件变量”。 条件变量用threading.Condition类创建
mycondition = threading.Condition()条件变量是如何工作的呢?首先一个线程成功获得一个条件变量后,调用此条件变量的wait()方法会导致这个线程释放这个锁,并进入“blocked”状态,直到另一个线程调用同一个条件变量的notify()方法来唤醒那个进入“blocked”状态的线程。如果调用这个条件变量的notifyAll()方法的话就会唤醒所有的在等待的线程。如果程序或者线程永远处于“blocked”状态的话,就会发生死锁。所以如果使用了锁、条件变量等同步机制的话,一定要注意仔细检查,防止死锁情况的发生。对于可能产生异常的临界区要使用异常处理机制中的finally子句来保证释放锁。等待一个条件变量的线程必须用notify()方法显式的唤醒,否则就永远沉默。保证每一个wait()方法调用都有一个相对应的notify()调用,当然也可以调用notifyAll()方法以防万一。
相关文章推荐
- python学习笔记——多线程同步问题
- 【python标准库学习】thread,threading(二)多线程同步
- python学习笔记——多线程同步问题
- python 的日志logging模块学习
- Python3学习(二)-递归函数、高级特性、切片
- python学习(字典使用字符串格式化)
- 机器学习之python基础(一)
- python学习之字符编码
- 【python学习笔记】4.数据类型和变量
- Python学习笔记 - 5.字符串(find方法,格式操作符%)
- Python学习总结:目录
- MySQL-python中间件的安装及Flask_SQLAlchemy的学习
- 你应该学习python的7个理由
- python pickle模块 分类: python学习 2014-12-01 16:01 129人阅读 评论(0) 收藏
- Python新手学习基础之数据结构-对数据结构的认知
- Python学习--15 日期和时间
- python基础学习之函数(3)-λ表达式,过滤器,map函数
- Opencv for Python 学习笔记 2.1 摄像头
- Python 学习
- Python学习第九天——列表