当前位置：首页 > 资讯 > 技术文档

java多线程之wait(),notify(),notifyAll()的详解分析

时间：2022-04-04 19:18 编辑：来源：阅读：
扫一扫，手机访问

摘要：java多线程之wait(),notify(),notifyAll()的详解分析

[b]wait(),notify(),notifyAll()[/b]不属于[b]Thread类[/b],而是属于[b]Object基础类[/b],也就是说每个对象都有[b]wait(),notify(),notifyAll()的功能[/b].因为每个对象都有锁,锁是每个对象的基础,当然操作锁的方法也是最基础了。 wait导致当前的线程等待，直到其他线程调用此对象的[b]notify()[/b] 方法或[b]notifyAll()[/b] 方法,或被其他线程中断。wait只能由持有对像锁的线程来调用。 notify唤醒在此对象监视器上等待的单个线程。如果所有线程都在此对象上等待，则会选择唤醒其中一个线程(随机)。直到当前的线程放弃此对象上的锁，才能继续执行被唤醒的线程。同Wait方法一样，notify只能由持有对像锁的线程来调用.notifyall也一样，不同的是notifyall会唤配所有在此对象锁上等待的线程。 "只能由持有对像锁的线程来调用"说明wait方法与notify方法必须在同步块内执行,即synchronized(obj)之内.再者synchronized代码块内没有锁是寸步不行的，所以线程要继续执行必须获得锁。相辅相成。 [b]看一个很经典的例子(生产者与消费者): 首先是消费者线程类： [/b]

[u]复制代码[/u] 代码如下:

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(1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    container.remove(0);
    container.notify();
    System.out.println("我吃了" + (++count) + "个");
   }
  }
 }
}

接下来是生产者线程类：

[u]复制代码[/u] 代码如下:

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(1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    container.add(new Object());
    container.notify();
    System.out.println("我生产了" + (++count) + "个");
   }
  }
 }
}

最后是测试类：

[u]复制代码[/u] 代码如下:

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;
 }
}

运行结果如下所示：

[u]复制代码[/u] 代码如下:

我生产了1个
我吃了1个
我生产了2个
我生产了3个
我生产了4个
我生产了5个
我生产了6个
我生产了7个
我吃了2个
我生产了8个
我吃了3个
我生产了9个
我吃了4个
我吃了5个
我吃了6个
我吃了7个
我吃了8个
我生产了10个
我生产了11个
我吃了9个
我生产了12个
我吃了10个
......

全部评论(0)

上一篇：java HttpURLConnection 发送文件和字符串信息
下一篇：Java的wait(), notify()和notifyAll()使用心得

资讯排行榜
更多>>