在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。