Java 线程通信模型小案例

package com.zhong.thread.usethread;import java.util.ArrayList;
import java.util.List;/*** @ClassName : CookAndFood* @Description : 锁的应用厨师和包子问题* @Author : zhx* @Date: 2024-02-19 15:43*/
public class CookAndFood {public static void main(String[] args) {Desk desk = new Desk();new Thread(() -> {while (true) {desk.put();}}, "厨师1").start();new Thread(() -> {while (true) {desk.put();}}, "厨师2").start();new Thread(() -> {while (true) {desk.put();}}, "厨师3").start();new Thread(() -> {while (true) {desk.get();}}, "顾客1").start();new Thread(() -> {while (true) {desk.get();}}, "顾客2").start();}
}/*** 类名称：$CLASSNAME$* 描述：桌子 存放包子* 创建人: zhong* 创建时间: 2024/02/19*/class Desk extends Thread {private List<String> desk = new ArrayList<>();public synchronized void put() {try {String name = Thread.currentThread().getName();if (desk.isEmpty()) {desk.add(name + "做得的包子");System.out.println(name + "做了一个包子");Thread.sleep(2000);// 唤醒别人 等待自己 注意顺序this.notifyAll();this.wait();} else {// 唤醒别人 等待自己 注意顺序// 有包子 尝试唤醒消费者this.notifyAll();this.wait();}} catch (InterruptedException e) {throw new RuntimeException(e);}}public synchronized void get() {try {String name = Thread.currentThread().getName();if (desk.size() == 1) {System.out.println(name + " 吃了包子 " + desk.get(0));// 清空集合 吃包子desk.clear();Thread.sleep(1000);this.notifyAll();this.wait();} else {this.notifyAll();this.wait();}} catch (Exception e) {throw new RuntimeException(e);}}
}