40. Java中线程间通信.docx

Java中线程间通信线程间通信（通讯）： 多个线程在处理同一个资源，但任务不同。一、 等待/唤醒机制：涉及的方法：（1） wait(); 使线程处于冻结状态，被wait的线程会存储到线程池（等待集）中；（2） notify(); 唤醒线程池中的一个线程，这个线程是任意的；（3） notifyAll（）； 唤醒线程池中的所有线程。 这些方法都必须定义在同步中，因为这些方法是用于操作线程状态的方法；而且必须要明确到底操作的是哪个锁上的线程。即必须明确线程由那个监视器监视。 监视器： 就是所说的锁。为什么操作线程的方法wait（）、notify（）、notifyAll（）定义在了Object类中？答：因为这些方法就是监视器的方法，监视器就是锁，锁可以是任意的对象，如 Object obj = new Object（）；既然可以是任意对象，那么这些方法需要定义在最高的类中，即定义在Object类中。线程间通信的示例：//创建一个资源类 ，存放资源class Resource { private String name; private String sex; private boolean flag = false; public synchronized void input(String name, String sex) {if (flag) try {this.wait(); } catch (InterruptedException e) { }this.name = name;this.sex = sex;flag = true;this.notify(); } public synchronized void output() {if (!flag) try {this.wait(); } catch (InterruptedException e) { }System.out.println(name + 的性别： + sex);flag = false;this.notify(); }}//创建输入的run方法，利用类对任务进行封装class Input implements Runnable { Resource r = null; Input(Resource r) {this.r = r; } public void run() {int x = 0;for (int i = 10; i 0; i--) { if (x == 0)r.input(KangKang, 男); elser.input(Jane, 女); x = (x + 1) % 2;} }}//利用类实现对输出任务的封装class Output implements Runnable { Resource r = null; Output(Resource r) {this.r = r; } public void run() {for (int i = 10; i 0; i--) r.output(); }}//主方法所在的类public class ThreadCommunication { public static void main(String[] args) {Resource r = new Resource();//创建一个资源对象，使下面两个线程同时操作同一个资源对象Input in = new Input(r);Output out = new Output(r);Thread tin = new Thread(in);Thread tout = new Thread(out);tin.start();tout.start(); }}结果：（实现一次赋值，一次输出，两个线程交替进行）KangKang 的性别： 男Jane 的性别： 女KangKang 的性别： 男Jane 的性别： 女KangKang 的性别： 男Jane 的性别： 女KangKang 的性别： 男Jane 的性别： 女KangKang 的性别： 男Jane 的性别： 女生产者—消费者模式：单生产者—单消费者模式：class Resource1 { private int count = 0;// 生产物品编号 private String name; private boolean flag = false; public synchronized void produce(String name) { this.name = name;if (flag) try {this.wait(); } catch (InterruptedException e) { }this.count++;System.out.println(生产的 + thi