目录
主要方法
1、主程序
2、生产者
3、消费者
4、中间队列（主要代码）
5、执行结果
主要方法
- wait(); 线程等待
- notify(); 通知一个等待的线程
- notifyAll(); 通知所有等待的线程
1、主程序
package xyz.jangle.thread.test.n2_3.synccondition;
/*** * 使用两个线程模拟生产者和消费者执行任务。* 1、生产者将队列填充满之后会通知消费者进行消费。（应该是等待消费者进行消费）* 2、消费者将队列消费为空之后，会通知生产者生产。（应该是等待生产者进行生产2024年1月3日10:10:16）* * 此处共同使用了EventStorage的对象锁，也就是synchronized方法锁，使用notify()方法进行通知。* @author jangle* @email jangle@jangle.xyz* @time 2020年7月16日 下午10:19:19* */
public class M {public static void main(String[] args) {EventStorage e = new EventStorage();Producer p = new Producer(e); // 生产者线程Consumer c = new Consumer(e); // 消费者线程new Thread(p).start();new Thread(c).start();}}
2、生产者
package xyz.jangle.thread.test.n2_3.synccondition;
/*** @author jangle* @email jangle@jangle.xyz* @time 2020年7月16日 下午10:16:21* */
public class Producer implements Runnable {private EventStorage storage;public Producer(EventStorage storage) {super();this.storage = storage;}@Overridepublic void run() {for(int i=0;i<100;i++) {storage.set();}}}
3、消费者
package xyz.jangle.thread.test.n2_3.synccondition;/*** @author jangle* @email jangle@jangle.xyz* @time 2020年7月16日 下午10:18:00* */
public class Consumer implements Runnable {private EventStorage storage;public Consumer(EventStorage storage) {super();this.storage = storage;}@Overridepublic void run() {for (int i = 0; i < 100; i++)storage.get();}}
4、中间队列（主要代码）
此处共同使用了EventStorage的对象锁，也就是synchronized方法锁，使用notify()方法进行通知。
package xyz.jangle.thread.test.n2_3.synccondition;import java.util.Date;
import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.TimeUnit;/*** @author jangle* @email jangle@jangle.xyz* @time 2020年7月16日 下午10:04:56* */
public class EventStorage {private int maxSize;private Queue<Date> storage;public EventStorage() {maxSize = 10;storage = new LinkedList<Date>();}public synchronized void set() {while(storage.size() == maxSize) {try {System.out.println("生产满");wait();} catch (InterruptedException e) {e.printStackTrace();}}try {TimeUnit.SECONDS.sleep(1);} catch (InterruptedException e) {e.printStackTrace();}storage.offer(new Date());System.out.printf("Set: %d",storage.size());notify();}public synchronized void get() {while(storage.size() == 0) {try {System.out.println("消费完");wait();} catch (InterruptedException e) {e.printStackTrace();}}try {TimeUnit.SECONDS.sleep(1);} catch (InterruptedException e) {e.printStackTrace();}String string = storage.poll().toString();System.out.printf("Get: %d:%s \n",storage.size(),string);notify();}}
5、执行结果
Set: 1Set: 2Set: 3Set: 4Set: 5Set: 6Set: 7Set: 8Set: 9Set: 10生产满
Get: 9:Wed Jan 03 14:37:43 CST 2024
Get: 8:Wed Jan 03 14:37:43 CST 2024
Get: 7:Wed Jan 03 14:37:43 CST 2024
Get: 6:Wed Jan 03 14:37:43 CST 2024
Get: 5:Wed Jan 03 14:37:43 CST 2024
Get: 4:Wed Jan 03 14:37:43 CST 2024
Get: 3:Wed Jan 03 14:37:43 CST 2024
Get: 2:Wed Jan 03 14:37:43 CST 2024
Get: 1:Wed Jan 03 14:37:43 CST 2024
Get: 0:Wed Jan 03 14:37:43 CST 2024
消费完
Set: 1Set: 2Set: 3Set: 4Set: 5Set: 6Set: 7Set: 8Set: 9Set: 10生产满
Get: 9:Wed Jan 03 14:37:43 CST 2024
Get: 8:Wed Jan 03 14:37:43 CST 2024
Get: 7:Wed Jan 03 14:37:43 CST 2024
Get: 6:Wed Jan 03 14:37:43 CST 2024
Get: 5:Wed Jan 03 14:37:43 CST 2024
Get: 4:Wed Jan 03 14:37:43 CST 2024
Get: 3:Wed Jan 03 14:37:43 CST 2024
Get: 2:Wed Jan 03 14:37:43 CST 2024
Get: 1:Wed Jan 03 14:37:43 CST 2024
Get: 0:Wed Jan 03 14:37:43 CST 2024
消费完
Set: 1Set: 2Set: 3Set: 4Set: 5Set: 6Set: 7Set: 8Set: 9Set: 10生产满
Get: 9:Wed Jan 03 14:37:43 CST 2024
Get: 8:Wed Jan 03 14:37:43 CST 2024
Get: 7:Wed Jan 03 14:37:43 CST 2024
Get: 6:Wed Jan 03 14:37:43 CST 2024
Get: 5:Wed Jan 03 14:37:43 CST 2024
Get: 4:Wed Jan 03 14:37:43 CST 2024
Get: 3:Wed Jan 03 14:37:43 CST 2024
Get: 2:Wed Jan 03 14:37:43 CST 2024
Get: 1:Wed Jan 03 14:37:43 CST 2024
Get: 0:Wed Jan 03 14:37:43 CST 2024
消费完
...
...
...
)
