【重学java】多线程基础（生产者消费者）-ag九游会j9官方网站

public class desk {

//定义一个标记

//true 就表示桌子上有汉堡包的,此时允许吃货执行

//false 就表示桌子上没有汉堡包的,此时允许厨师执行

public static boolean flag = false;

//汉堡包的总数量

public static int count = 10;

//锁对象

public static final object lock = new object();

}

public class cooker extends thread {

// 生产者步骤：

// 1，判断桌子上是否有汉堡包

// 如果有就等待，如果没有才生产。

// 2，把汉堡包放在桌子上。

// 3，叫醒等待的消费者开吃。

@override

public void run() {

while(true){

synchronized (desk.lock){

if(desk.count == 0){

break;

}else{

if(!desk.flag){

//生产

system.out.println("厨师正在生产汉堡包");

desk.flag = true;

desk.lock.notifyall();

}else{

try {

desk.lock.wait();

} catch (interruptedexception e) {

public class desk {

//定义一个标记

//true 就表示桌子上有汉堡包的,此时允许吃货执行

//false 就表示桌子上没有汉堡包的,此时允许厨师执行

//public static boolean flag = false;

private boolean flag;

//汉堡包的总数量

//public static int count = 10;

//以后我们在使用这种必须有默认值的变量

// private int count = 10;

private int count;

//锁对象

//public static final object lock = new object();

private final object lock = new object();

public desk() {

this(false,10); // 在空参内部调用带参,对成员变量进行赋值,之后就可以直接使用成员变量了

}

public desk(boolean flag, int count) {

this.flag = flag;

this.count = count;

}

public boolean isflag() {

return flag;

}

public void setflag(boolean flag) {

this.flag = flag;

}

public int getcount() {

public class demo02 {

public static void main(string[] args) throws exception {

// 创建阻塞队列的对象,容量为 1

arrayblockingqueue arrayblockingqueue = new arrayblockingqueue<>(1);

// 存储元素

arrayblockingqueue.put("汉堡包");

// 取元素

system.out.println(arrayblockingqueue.take());

system.out.println(arrayblockingqueue.take()); // 取不到会阻塞

system.out.println("程序结束了");

}

}