生产者和消费者模式：一个线程负责生产，一个线程负责消费，最终要让生产者和消费者必须均衡。 wait()和notify()方法建立在synchronized线程同步的基础之上。 ** 对象.wait()方法会让正在该对象上活动的当前线程进入等待状态，并且释放之前占有的该对象的锁。 对象.notify()方法只会通知，不会释放之前占有的该对象的锁。 ** 一个经典例子: 使用生产者和消费者模式实现，交替输出： 假设只有两个线程，输出以下结果： t1–>1 t2–>2 t1–>3 t2–>4 t1–>5 t2–>6 …
代码语言：javascript复制 要求：必须交替输出，并且t1线程负责输出奇数。t2线程负责输出偶数。
两个线程共享一个数字package com.java.exam;
/*
使用多线程进行交替输出奇数偶数。t1输出奇数，t2输出偶数。
*/
public class ProductTest {
public static void main(String[] args) {
Num num = new Num() ;
Thread t1 = new Thread(new Odd(num));
Thread t2 = new Thread(new Even(num));
t1.setName("t1");
t2.setName("t2");
t1.start();
t2.start();
}
}
class Num {
int i = 1;
}
class Odd implements Runnable {
private Num num;
public Odd(Num num) {
this.num = num;
}
@Override
public void run() {
while(true) {
synchronized (num) {
if(num.i % 2 == 0) {
try {
Thread.sleep(1000);//睡眠一秒能更好看到执行结国
//当前线程进入等待状态，并且释放Odd之前占有的num的锁
num.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//程序可以执行到这说明num是奇数
System.out.println(Thread.currentThread().getName() "---->" num.i );
num.notifyAll();
}
}
}
}
class Even implements Runnable {
private Num num;
public Even(Num num) {
this.num = num;
}
@Override
public void run() {
while(true) {
synchronized (num) {
if(num.i % 2 == 1) {
try {
Thread.sleep(1000);
//当前线程进入等待状态，并且释放Even之前占有的num的锁
num.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
程序可以执行到这说明num是偶数
System.out.println(Thread.currentThread().getName() "---->" num.i );
num.notifyAll();
}
}
}
}
