Java多线程sleep(),join(),interrupt(),wait(),notify()（转）

关于Java多线程知识可以看看《Thinking in Java 》中的多线程部分和《Java网络编程》中第5章多线程的部分

以下是参考<<Java多线程模式>>的
1. sleep() & interrupt()
    线程A正在使用sleep()暂停着: Thread.sleep(100000);
    如果要取消他的等待状态,可以在正在执行的线程里(比如这里是B)调用
        a.interrupt();
    令线程A放弃睡眠操作,这里a是线程A对应到的Thread实例
    执行interrupt()时,并不需要获取Thread实例的锁定.任何线程在任何时刻,都可以调用其他线程interrupt().当sleep中的线程被调用interrupt()时,就会放弃暂停的状态.并抛出InterruptedException.丢出异常的,是A线程.

2. wait() & interrupt()
    线程A调用了wait()进入了等待状态,也可以用interrupt()取消.
    不过这时候要小心锁定的问题.线程在进入等待区,会把锁定解除,当对等待中的线程调用interrupt()时(注意是等待的线程调用其自己的interrupt()) ,会先重新获取锁定,再抛出异常.在获取锁定之前,是无法抛出异常的.

3. join() & interrupt()
    当线程以join()等待其他线程结束时,一样可以使用interrupt()取消之.因为调用join()不需要获取锁定,故与sleep()时一样,会马上跳到catch块里. 注意是随调用interrupt()方法,一定是阻塞的线程来调用其自己的interrupt方法.如在线程a中调用来线程t.join().则a会等t执行完后在执行t.join后的代码,当在线程b中调用来a.interrupt()方法,则会抛出InterruptedException

4. interrupt()只是改变中断状态而已
    interrupt()不会中断一个正在运行的线程。这一方法实际上完成的是，在线程受到阻塞时抛出一个中断信号，这样线程就得以退出阻塞的状态。更确切的说，如果线程被Object.wait, Thread.join和Thread.sleep三种方法之一阻塞，那么，它将接收到一个中断异常（InterruptedException），从而提早地终结被阻塞状态。
    如果线程没有被阻塞，这时调用interrupt()将不起作用；否则，线程就将得到异常（该线程必须事先预备好处理此状况），接着逃离阻塞状态。
    线程A在执行sleep,wait,join时,线程B调用A的interrupt方法,的确这一个时候A会有InterruptedException 异常抛出来.但这其实是在sleep,wait,join这些方法内部会不断检查中断状态的值,而自己抛出的InterruptedException。
    如果线程A正在执行一些指定的操作时如赋值,for,while,if,调用方法等,都不会去检查中断状态,所以线程A不会抛出 InterruptedException,而会一直执行着自己的操作.当线程A终于执行到wait(),sleep(),join()时,才马上会抛出 InterruptedException.
    若没有调用sleep(),wait(),join()这些方法,或是没有在线程里自己检查中断状态自己抛出InterruptedException的话,那InterruptedException是不会被抛出来的.

顺便加个与Thread.sleep()相同效果的代码:
public static void amethod(long x) throws InterruptedExcetion{
    if (x != 0) {
        Object o = new Object();
        synchronized (o) {
            o.wait(x);
        }
    }
}

 

 

wait(),notify(),notifyAll()不属于Thread类,而是属于Object基础类,也就是说每个对像都有wait(),notify(),notifyAll()
的功能.因为都个对像都有锁,锁是每个对像的基础,当然操作锁的方法也是最基础了.
先看java doc怎么说:
 wait导致当前的线程等待，直到其他线程调用此对象的 notify() 方法或 notifyAll() 方法。当前的线程必须拥有此对象监视器。该线程发布对此监视器的所有权并等待，直到其他线程通过调用 notify 方法，或 notifyAll 方法通知在此对象的监视器上等待的线程醒来。然后该线程将等到重新获得对监视器的所有权后才能继续执行.

 notify唤醒在此对象监视器上等待的单个线程。如果所有线程都在此对象上等待，则会选择唤醒其中一个线程。直到当前的线程放弃此对象上的锁定，才能继续执行被唤醒的线程。此方法只应由作为此对象监视器的所有者的线程来调用.

"当前的线程必须拥有此对象监视器"与"此方法只应由作为此对象监视器的所有者的线程来调用"说明wait方法与notify方法必须在同步块内执行,即synchronized(obj之内).

调用对像wait方法后,当前线程释放对像锁,进入等待状态.直到其他线程(也只能是其他线程)通过notify 方法，或 notifyAll.该线程重新获得对像锁.
继续执行,记得线程必须重新获得对像锁才能继续执行.因为synchronized代码块内没有锁是寸步不能走的.看一个很经典的例子:

package  ProductAndConsume;

import  java.util.List;

public   class  Consume  implements  Runnable{
     private  List container  =   null ;
     private   int  count;
     public  Consume(List lst){
      this .container  =  lst;
    }
  public   void  run() {
  
   while ( true ){
    synchronized  (container) {
     if (container.size() ==   0 ){//生产者和消费者都要先判断，再看是不是要等待，还是立即可以执行
      try  {
      container.wait(); // 放弃锁 
     }  catch  (InterruptedException e) {
      e.printStackTrace();
     }
    }
     try  {
     Thread.sleep( 100 );
    }  catch  (InterruptedException e) {
      //  TODO Auto-generated catch block 
     e.printStackTrace();
    }
    container.remove( 0 );
    container.notify();//生产者与消费者是相互通知的
    System.out.println( " 我吃了 " + ( ++ count) + " 个 " );
   }
  }
  
 }

}

 

package  ProductAndConsume;

import  java.util.List;

public   class  Product  implements  Runnable {
  private  List container  =   null ;
     private   int  count;
  public  Product(List lst) {
   this .container  =  lst;
 }

  public   void  run() {
   while  ( true ) {
    synchronized  (container) {
     if  (container.size()  >  MultiThread.MAX) {//生产者和消费者都要先判断，再看是不是要等待，还是立即可以执行
      try  {
      container.wait();
     }  catch  (InterruptedException e) {
      e.printStackTrace();
     }
    }
     try  {
     Thread.sleep( 100 );
    }  catch  (InterruptedException e) {
     e.printStackTrace();
    }
    container.add( new  Object());
    container.notify();//生产者与消费者是相互通知的
    System.out.println( " 我生产了 " + ( ++ count) + " 个 " );
   }
  }

 }

}

 

package  ProductAndConsume;

import  java.util.ArrayList;
import  java.util.List;

public   class  MultiThread {
  private  List container  =   new  ArrayList();


 public final static int MAX = 5;

 

  public static void main(String args[]){

 MultiThread m  =   new  MultiThread(); 

   new  Thread( new  Consume(m.getContainer())).start();
   new  Thread( new  Product(m.getContainer())).start();
   new  Thread( new  Consume(m.getContainer())).start();
   new  Thread( new  Product(m.getContainer())).start();
 }
  public  List getContainer() {
   return  container;
 }

  public   void  setContainer(List container) {
   this .container  =  container;
 }
}

 

评论

1 楼 javer 2010-12-29