java 多线程之wait,notify,sleep,join

 java多线程编程离不开锁，和锁管的几个函数有wait,notify,sleep,join等

 

 首先来看这个几个方法的结构以及所在的类

 

 wait和notify以及notifyAll 都是在java的超类Object里面，这样设计的目的，个人见解可能是实现面向对象的需要，把每个对象都放在jvm的等待队列里面

 

  sleep和join  都是在类thread中

 

  作用:

   sleep()方法 : 使当前线程进入停滞状态（阻塞当前线程），让出CUP的使用、目的是不让当前线程独自霸占该进程所获的CPU资源，以留一定时间给其他线程执行的机会;
　　 sleep()是Thread类的Static(静态)的方法；因此他不能改变对象的机锁，所以当在一个Synchronized块中调用Sleep()方法是，线程虽然休眠了，但是对象的机锁并木有被释放，其他线程无法访问这个对象（即使睡着也持有对象锁）。
　　在sleep()休眠时间期满后，该线程不一定会立即执行，这是因为其它线程可能正在运行而且没有被调度为放弃执行，除非此线程具有更高的优先级。

 

    wait()方法 : Object类里的方法；当一个线程执行到wait()方法时，它就进入到一个和该对象相关的等待池中，同时失去（释放）了对象的机锁（暂时失去机锁，wait(long timeout)超时时间到后还需要返还对象锁）；其他线程可以访问；
　　wait()使用notify或者notifyAlll或者指定睡眠时间来唤醒当前等待池中的线程。
　　wiat()必须放在synchronized block中，否则会在program runtime时扔出出”java.lang.IllegalMonitorStateException“异常

   

     notify以及notifyAll:唤醒该对象等待池中的对象继续执行工作

     Join：必须在线程调用start方法之后才能调用，不然则不起作用，具体的可以查看jvm的thread的源码，join方法的作用就是等待某个线程的终止

 

    需要注意的是notify和wait的实现，必须有对象锁的实现，不然就会爆出IllegalMonitorStateException异常

 

    以下为用wait以及notify实现的消费者-生产者的例子

 

    /**    
* QueueBuffer.java Create on 2014年8月5日   
*    
* Copyright (c) 2014年8月5日 by dzh
*    
* @author <a href="[e-mail]">xingyu</a>   
* @version 0.0.1
*   
*/
package org.dzh.thread.setAndget;

/**@className:QueueBuffer.java

 * @description:消费池子队列

 * @date 2014年8月5日 下午4:48:26
 */
public class QueueBuffer {

    private int num;
   
    /**是否被设置值*/
    private boolean valueSet = false;
   
    synchronized int get(){
        if(!valueSet){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        valueSet = false;
        notify();
        return num;
    }
   
   
    synchronized void set(int n){
       
        if(valueSet){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        valueSet = true;
        notify();
        this.num = n;
    }
   
}
/**    
* Product.java Create on 2014年8月5日   
*    
* Copyright (c) 2014年8月5日 by dzh
*    
* @author <a href="[e-mail]">xingyu</a>   
* @version 0.0.1
*   
*/
package org.dzh.thread.setAndget;

/**@className:Product.java

 * @description:生产者

 * @date 2014年8月5日 下午4:57:25
 */
    public class Product extends Thread{
       private QueueBuffer qb;
      
        public Product(QueueBuffer qb,String name){
            super(name);
            this.qb = qb;
        }
       
        @Override
        public void run() {
            int num = 1;
           
            for (; ; ) {
                qb.set(num);
                num++;
            }
        }
    }

 

/**    
* Consumer.java Create on 2014年8月5日   
*    
* Copyright (c) 2014年8月5日 by dzh
*    
* @author <a href="[e-mail]">xingyu</a>   
* @version 0.0.1
*   
*/
package org.dzh.thread.setAndget;

/**@className:Consumer.java

 * @description:消费者

 * @date 2014年8月5日 下午4:57:49
 */
public class Consumer extends Thread{
    private QueueBuffer qb;
       
    public Consumer(QueueBuffer qb,String name){
        super(name);
        this.qb = qb;
    }
   
    @Override
    public void run() {
        System.out.println(qb.get());
    }
}