从notify-wait模式说去

在java的并发编程之中，有几个比较重要的模式，其中notify-wait的模式显得很重要，因为他是经典的生产者-消费者模式实现的基础，而在生产者-消费者模式上，又可以演变出很多的设计方法，比如java的线程池就是典型的生产者消费者模式，今天就来说一下notify-wait

首先说一下wait在notify之后的的执行逻辑

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。