在java的并发编程之中,有几个比较重要的模式,其中notify-wait的模式显得很重要,因为他是经典的生产者-消费者模式实现的基础,而在生产者-消费者模式上,又可以演变出很多的设计方法,比如java的线程池就是典型的生产者消费者模式,今天就来说一下notify-wait
首先说一下wait在notify之后的的执行逻辑
在Java对象中,有两种池
琐池-----------------------synchronized
等待池---------------------wait(),notify(),notifyAll()
如果一个线程调用了某个对象的wait方法,那么该线程进入到该对象的等待池中(并且已经将锁释放),
如果未来的某一时刻,另外一个线程调用了相同对象的notify方法或者notifyAll方法,
那么该等待池中的线程就会被唤起,然后进入到对象的锁池里面去获得该对象的锁, 如果获得锁成功后,那么该线程就会沿着wait方法之后的路径继续执行。注意是沿着wait方法之后
notify-wait需要在同步的环境下使用,一般套用的方法是:
1,获取对象的锁
2,如果条件不满足,那么调用对象的wait方法,被通知后仍然要检查条件,之所以需要条件检查,是因为被通知后仍然需要获取对象锁,也因此,一般条件检查部分都需要使用while循环来检查
3,条件满足则执行下面对应的逻辑
伪码如下:
synchronized(对象){
while(条件不满足){
对象.wait();
}
对应的处理逻辑
}
通知方遵循的规则如下:
1,获取对象的锁
2,改变现有条件
3,通知所有等待在对象上的线程
synchronized(对象){
改变条件
对象.notify();
}
话不多说,上代码分析
package com.luchi.threadPoolSimulation; import java.sql.Connection; import java.util.LinkedList; public class ConnectionPool { private LinkedList<Connection> pool=new LinkedList<>(); public ConnectionPool(int initialSize){ //初始化threadPool for(int i=0;i<initialSize;i++){ pool.addLast(ConnectionDriver.createConnection()); } } public void releaseConnection(Connection conn){ if(conn!=null){ synchronized (pool) { //获取锁 pool.addLast(conn); //更改条件 pool.notifyAll(); //通知 } } } public Connection fetchConnection(int mill) throws InterruptedException{ synchronized (pool) { //获取锁 if(mill<=0){ while(pool.isEmpty()){ pool.wait(); } return pool.getLast(); }else{ long Future=System.currentTimeMillis()+mill; long remain=mill; while(pool.isEmpty() && remain>0){ //循环检查条件 pool.wait(remain); //条件不满足陷入等待 remain=Future-System.currentTimeMillis(); } //条件满足或者超时执行下面逻辑 Connection result=null; if(!pool.isEmpty()){ result=pool.removeFirst(); } return result; } } } }
代码说明:
代码模拟java的数据库连接池,其中fetchConnection是取connection连接,releaseConnection是释放连接,代码的构造函数初始化了这个connection连接池的大小。
首先来看一下取连接:
取连接加入了超时检查模型,也就是说如果在没有取得连接的情况下过了指定的一段时间,将不会再次陷入wait之中而是接着执行(返回null),代码完全遵守之前描述的等待原则,先获取锁,然后循环检查条件,执当检查条件满足或者超时的情况下接着往下面行
然后再看一下释放连接的releaseCOnnection,同样还是遵循之前描述的模型,获取锁-更改条件-执行逻辑
了解这这个,下回就可以分析JDK1.7中的线程池的源码了,over。
相关推荐
使用Java多线程的wait和notify方法实现最简单的生产者消费者模式
wait set——线程的休息室 wait方法——把线程放入wait set notify方法——从wait set拿出线程 notifyAll方法——从wait set拿出所有线程 wait、notify、notifyAll是Object类的方法 线程的状态移转 跟线程有关的其他...
1.notify的使用 2. wait的使用 3. linux系统下的开发 4.多线程通信 5. 生产者和消费者模式
java多线程设计模式 线程的创建和重起 线程的同步 wait/notify/sleep机制 Worker Pattern
读者将通过使用java.lang.thread类、synchronized和volatile关键字,以及wait、notify和notifyall方法,学习如何初始化、控制和协调并发操作。此外,本书还提供了有关并发编程的全方位的详细内容,例如限制和同步、...
wait()、notify()和notifyAll() wait()和sleep() 线程中断 静态方法(有关同步的细节) 总结 第五章 Java线程编程的例子 数据结构和容器 简单的同步例子 一个网络服务器类 AsyncInputStream类 使用TCP...
生产者和消费者是一个十分经典的多线程协作模式 **常见方法:** - void wait() 当前线程等待,直到被其他线程唤醒 - void notify() 随机唤醒单个线程 - void notifyAll() 唤醒所有线程
│ 高并发编程第二阶段34讲、多线程Two Phase Termination设计模式-上.mp4 │ 高并发编程第二阶段35讲、多线程Two Phase Termination设计模式-下.mp4 │ 高并发编程第二阶段36讲、多线程Worker-Thread设计模式-上...
│ 高并发编程第二阶段34讲、多线程Two Phase Termination设计模式-上.mp4 │ 高并发编程第二阶段35讲、多线程Two Phase Termination设计模式-下.mp4 │ 高并发编程第二阶段36讲、多线程Worker-Thread设计模式-上...
读者将通过使用java.lang.thread类、synchronized和volatile关键字,以及wait、notify和notifyall方法,学习如何初始化、控制和协调并发操作。此外,本书还提供了有关并发编程的全方位的详细内容,例如限制和同步、...
生产者消费者模式是java多线程经典的安全,它用到了同步,资源共享,wait,notify等技术。
cd /user/s0807 从绝对路径去到某目录。 cd ~/s0807 直接进入主目录下的某目录(“cd ~"相当于主目录的路径的简写)。 ls 显示当前目录的所有目录和文件。 用法 ls [-aAbcCdeEfFghHilLmnopqrRstux1@] [file...] ls...
使用Condition重写waitnotify案例并实现一个有界队列.mp4 深入解析Condition源码.mp4 实战:简易数据连接池.mp4 线程之间通信之join应用与实现原理剖析.mp4 ThreadLocal 使用及实现原理.mp4 并发工具类...
, 这里,读者将通过使用java.lang.thread类、synchronized和volatile关键字,以及wait、notify和notifyall方法,学习如何初始化、控制和协调并发操作。此外,本书还提供了有关并发编程的全方位的详细内容,例如限制...
wait方法如果不是同步监视器去调用的话会报IllegalMonitorStateException异常 如果没有线程处于wait状态,调用notify此时是一个空唤醒 stringBuffer中的同步方法,都是非静态的,因为共用一个this锁就可以了,线程...
这种机制是轻量级的,它使用server端的servlet连接管理、线程工具、javax.servlet API,并通过标准Java特性中Object的wait()和notify()实现的生产者/消费者机制。原则上,Pushlet框架能够运行在任何支持servlet的...
wait是Object类的方法,对此对象调用wait方法导致本线程放弃对象锁,进入等待此对象的等待锁定池,只有针对此对象发出notify方法(或notifyAll)后本线程才进入对象锁定池准备获得对象锁进入运行状态。 17、...
例如:synchronized、wait()、notify()不过是操作系统领域里管程模型的一种实现而已 钻进去,看本质 探究 Doug Lea 大师在J.U.C 包创造的章法 知识体系全景图 2.抽象问题总结 并发程序的背后 CPU 增加了缓存,以均衡...
wait是Object类的方法,对此对象调用wait方法导致本线程放弃对象锁,进入等待此对象的等待锁定池,只有针对此对象发出notify方法(或notifyAll)后本线程才进入对象锁定池准备获得对象锁进入运行状态。 14、Overload...
88. 说一下你熟悉的设计模式? 49 89. 简单工厂和抽象工厂有什么区别? 49 十、Spring / Spring MVC 52 90. 为什么要使用 spring? 52 91. 解释一下什么是 aop? 53 92. 解释一下什么是 ioc? 54 93. spring 有哪些...