java多線程之wait(),notify(),notifyAll()的詳解分析

2019-11-26 16:04:17

字體：大中小

供稿：網(wǎng)友

wait(),notify(),notifyAll()不屬于Thread類,而是屬于Object基礎(chǔ)類,也就是說每個對象都有wait(),notify(),notifyAll()的功能.因為每個對象都有鎖,鎖是每個對象的基礎(chǔ),當然操作鎖的方法也是最基礎(chǔ)了。

wait導致當前的線程等待，直到其他線程調(diào)用此對象的 notify() 方法或 notifyAll() 方法,或被其他線程中斷。wait只能由持有對像鎖的線程來調(diào)用。

notify喚醒在此對象監(jiān)視器上等待的單個線程。如果所有線程都在此對象上等待，則會選擇喚醒其中一個線程(隨機)。直到當前的線程放棄此對象上的鎖，才能繼續(xù)執(zhí)行被喚醒的線程。同Wait方法一樣，notify只能由持有對像鎖的線程來調(diào)用.notifyall也一樣，不同的是notifyall會喚配所有在此對象鎖上等待的線程。
"只能由持有對像鎖的線程來調(diào)用"說明wait方法與notify方法必須在同步塊內(nèi)執(zhí)行,即synchronized(obj)之內(nèi).再者synchronized代碼塊內(nèi)沒有鎖是寸步不行的，所以線程要繼續(xù)執(zhí)行必須獲得鎖。相輔相成。
看一個很經(jīng)典的例子(生產(chǎn)者與消費者):
首先是消費者線程類：

復制代碼代碼如下:

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();// 容器為空，放棄鎖，等待生產(chǎn)
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
    try {
     Thread.sleep(1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    container.remove(0);
    container.notify();
    System.out.println("我吃了" + (++count) + "個");
   }
  }
 }
}

接下來是生產(chǎn)者線程類：

復制代碼代碼如下:

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) {
     // 如果容器超過了最大值，就不要在生產(chǎn)了，等待消費
     try {
      container.wait();
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
    try {
     Thread.sleep(1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    container.add(new Object());
    container.notify();
    System.out.println("我生產(chǎn)了" + (++count) + "個");
   }
  }
 }
}

最后是測試類：

復制代碼代碼如下:

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();
 }
 public List getContainer() {
  return container;
 }
 public void setContainer(List container) {
  this.container = container;
 }
}

運行結(jié)果如下所示：

復制代碼代碼如下:

我生產(chǎn)了1個
我吃了1個
我生產(chǎn)了2個
我生產(chǎn)了3個
我生產(chǎn)了4個
我生產(chǎn)了5個
我生產(chǎn)了6個
我生產(chǎn)了7個
我吃了2個
我生產(chǎn)了8個
我吃了3個
我生產(chǎn)了9個
我吃了4個
我吃了5個
我吃了6個
我吃了7個
我吃了8個
我生產(chǎn)了10個
我生產(chǎn)了11個
我吃了9個
我生產(chǎn)了12個
我吃了10個
......