java 多线程&不使用wait/notify机制实现线程间通信——60

使用sleep()结合while（true）死循环法来实现多个线程间的通信。

类MyList.java代码

package chapter3.test3_1.test3_1_1;

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

public class MyList {
    volatile private List list = new ArrayList();

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

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

对变量： volatile private List list = new ArrayList(); 添加 volatile 关键字，以实现 A 线程和 B线程间的可视性。

线程类ThreadA.java代码

package chapter3.test3_1.test3_1_1;


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("ThreadA添加了" + (i + 1) + "个元素");
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

线程类ThreadB.java代码

package chapter3.test3_1.test3_1_1;

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("list.size()==5了，线程b要退出了！");
                    throw new InterruptedException();
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

运行类Test.java代码

package chapter3.test3_1.test3_1_1;

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

程序运行结果

虽然两个线程间实现了通信，但缺点是线程ThreadB.java 不停地通过 while语句轮询机制来检测某一个条件，这样会浪费 CPU 资源。

如果轮询的时间间隔很小，则更浪费CPU资源；如果轮询的时间间隔很大，则有可能取不到想要的数据例如修改ThreadB后如下

package chapter3.test3_1.test3_1_1.test1;

public class ThreadB extends Thread {
    private MyList list;

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

    @Override
    public void run() {
        try {
            while (true) {
                Thread.sleep(2000);
                System.out.println("ThreadB循环");
                if (list.size() == 5) {
                    System.out.println("eeeeeeeeeeeeeeexit");
                    throw new InterruptedException();
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

运行结果

总结

添加 Thread.sleep （ 2000 ）代码后， B线程并没有退出，所以需要引入一种机制 ——wait/notify（等待 / 通知）机制，以减少 CPU资源浪费，还可以实现在多个线程间随时通信。

java 多线程&不使用wait/notify机制实现线程间通信——60

Java相关栏目本月热门文章