《java多线程编程核心技术》不使用等待通知机制实现线程间通信的疑问分析

2022-09-09 09:21:09

不使用等待通知机制实现线程间通信的疑问分析

2018年04月03日 17:15:08 ayf

阅读数：33 编辑

《java多线程编程核心技术》一书第三章开头，有如下案例：

线程A：

package extthread;  

import mylist.MyList;  

public class ThreadA extends Thread {  

    private MyList list;  

    public ThreadA(MyList list) {
        super();
        this.list = list;
    }  

    @Override
    public void run() {
        try {
            for (int i = 0; i < 10; i++) {
                list.add();
                System.out.println("添加了" + (i + 1) + "个元素");
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }  

}

线程B：

package extthread;  

import mylist.MyList;  

public class ThreadB extends Thread {  

    private MyList list;  

    public ThreadB(MyList list) {
        super();
        this.list = list;
    }  

    @Override
    public void run() {
        try {
            while (true) {
                if (list.size() == 5) {
                    System.out.println("==5了，线程b要退出了！");
                    throw new InterruptedException();
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }  

}

MyList.java代码：

package mylist;  

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

public class MyList {  

    private List list = new ArrayList();  

    public void add() {
        list.add("高洪岩");
    }  

    public int size() {
        return list.size();
    }  

}

运行类Test.java代码：

package test;  

import mylist.MyList;  

import java.util.concurrent.ThreadPoolExecutor;  

import extthread.ThreadA;
import extthread.ThreadB;  

public class Test {  

    public static void main(String[] args) {
        MyList service = new MyList();  

        ThreadA a = new ThreadA(service);
        a.setName("A");
        a.start();  

        ThreadB b = new ThreadB(service);
        b.setName("B");
        b.start();  

    }  

}

程序执行，按照书中所描述，应该出现如图所示结果：B线程抛出异常，停止运行。

但是实际上本地运行结果如下，没有抛出异常：B线程还是一直在进行while循环

这让我十分困惑。就进行各种测试，我在B线程的while循环体里面，加了一句打印代码，B线程的while循环代码变为如下：

while (true) {
                System.out.println(list.size());
                if (list.size() == 5) {
                    System.out.println("==5了，线程b要退出了！");
                    throw new InterruptedException();
                }
            }

再次执行，竟然发现能够打印出异常了，既然异常抛出，那肯定B线程停了，等A运行结束，虚拟机也停止运行了。如图：

只是添加了一句打印的代码，竟然会影响程序的执行逻辑？？？这是什么原因？另外，我又继续做了如下测试：

1.    while (true) {
2.                    //System.out.println("B一直在执行");
3.                    int a = 10;
4.                    if (list.size() == 5) {
5.                        System.out.println("==5了，线程b要退出了！");
6.                        throw new InterruptedException();
7.                    }
8.                }

把上面说的那一句system.out.println改为 int a = 10;====》B线程不能抛出异常，A线程循环输出完毕，虚拟机不停。