• java 多线程&使用wait/notify机制实现list.size()等于5时 的线程销毁——65

    下面通过一个示例来演示如何使用 wait() 与notify() 来实现前面 list.size() 值等于 5 时的线程销毁

    类MyList.java代码

    1. package chapter3.test3_1.test3_1_6;
    2.  
    3. import java.util.ArrayList;
    4. import java.util.List;
    5.  
    6. public class MyList {
    7.     private static List list = new ArrayList();
    8.  
    9.     public static void add() {
    10.         list.add("anyString");
    11.     }
    12.  
    13.     public static int size() {
    14.         return list.size();
    15.     }
    16. }

    类ThreadA.java代码

    1. package chapter3.test3_1.test3_1_6;
    2.  
    3. public class ThreadA extends Thread {
    4.     private Object lock;
    5.  
    6.     public ThreadA(Object lock) {
    7.         super();
    8.         this.lock = lock;
    9.     }
    10.  
    11.     @Override
    12.     public void run() {
    13.         try {
    14.             synchronized (lock) {
    15.                 if (MyList.size() != 5) {
    16.                     System.out.println("wait begin " + System.currentTimeMillis());
    17.                     lock.wait();
    18.                     System.out.println("wait end " + System.currentTimeMillis());
    19.                 }
    20.             }
    21.         } catch (InterruptedException e) {
    22.             e.printStackTrace();
    23.         }
    24.     }
    25. }

    类ThreadB.java代码

    1. package chapter3.test3_1.test3_1_6;
    2.  
    3. public class ThreadB extends Thread {
    4.     private Object lock;
    5.  
    6.     public ThreadB(Object lock) {
    7.         super();
    8.         this.lock = lock;
    9.     }
    10.  
    11.     @Override
    12.     public void run() {
    13.         try {
    14.             synchronized (lock) {
    15.                 for (int i = 0; i < 10; i++) {
    16.                     MyList.add();
    17.                     if (MyList.size() == 5) {
    18.                         lock.notify();
    19.                         System.out.println("已发出通知！");
    20.                     }
    21.                     System.out.println("添加了" + (i + 1) + "个元素!");
    22.                     Thread.sleep(1000);
    23.                 }
    24.             }
    25.         } catch (InterruptedException e) {
    26.             e.printStackTrace();
    27.         }
    28.     }
    29. }

    类Run.java代码

    1. package chapter3.test3_1.test3_1_6;
    2.  
    3. public class Run {
    4.     public static void main(String[] args) {
    5.         try {
    6.             Object lock = new Object();
    7.             ThreadA a = new ThreadA(lock);
    8.             a.start();
    9.             Thread.sleep(50);
    10.             ThreadB b = new ThreadB(lock);
    11.             b.start();
    12.         } catch (InterruptedException e) {
    13.             e.printStackTrace();
    14.         }
    15.     }
    16. }

    程序运行结果

    日志信息 wait end 在最后输出，这说明notify()方法 执行后并不立即释放锁 
            关键字synchronized 可以将任何一个Object对象作为锁来看待，而Java为每个Object都实现了wait()和notify()方法，它们必须用在被synchronized同步的Object的临界区内。通过调用wait()方法可以使处于临界区内的线程进入等待状态，同时释放被同步对象的锁，而notify操 作可以唤醒一个因调用了wait操作而处于wait状态中的线程，使其进入就绪状态，被重新唤醒的线程会试图重新获得临界区的控制权，也就是锁，并继续执行临界区内wait之后的代码。如果发出notify操作时没有处于wait状态中的线程，那么该命令会被忽略。
           wait()方法可以使调用该方法的线程释放锁，然后从运行状态转换成wait状态，等待被唤醒。

            notify()方法按照执行wait()方法的顺序唤醒等待同一锁的“一个”线程，使其进入可运行状态，即notify()方法仅通知“一个”线程。

            notifyAll()方法执行后，会按照执行wait()方法相反的顺序依次唤醒全部的线程。

     

  • 相关阅读:
    高速DSP系统设计参考指南（一）高速DSP设计面临的挑战
    QT多线程的四种实现方式之一：QThread类的run
    简单的购物车
    10min快速回顾C++语法（三）
    可变字符串
    比 N 小的最大质数
    centos7安装chrome/Firefox浏览器
    GDB Debugging Notes
    Qt listWidget 详细分析
    基于qt软件的网上聊天室软件
  • 原文地址：https://blog.csdn.net/zp357252539/article/details/125460060