Java如何通过线程解决生产者/消费者问题

网友投稿 280 2022-11-18


Java如何通过线程解决生产者/消费者问题

生产者和消费者问题是线程模型中的经典问题:生产者和消费者在同一时间段内共用同一个存储空间,如下图所示

生产者向空间里存放数据,而消费者取用数据,如果不加以协调可能会出现以下情况:

存储空间已满,而生产者占用着它,消费者等着生产者让出空间从而去除产品,生产者等着消费者消费产品,从而向空间中添加产品。互相等待,从而发生死锁。

以下实例演示了如何通过线程解决生产者/消费者问题:

/*

author by javaidea.com

ProducerConsumerTest.java

*/

public class ProducerConsumerTeshttp://t {

public static void main(String[] args) {

CubbyHole c = new CubbyHole();

Producer p1 = new Producer(c, 1);

Consumer c1 = new Consumer(c, 1);

p1.start();

c1.start();

}

}

class CubbyHole {

private int contents;

private boolean available = false;

public synchronized int get() {

while (available == false) {

try {

wait();

}

catch (InterruptedException e) {

}

}

available = false;

notifyAll();

return contents;

}

public synchronized void put(int value) {

while (available == true) {

try {

wait();

}

catch (InterruptedException e) {

}

}

contents = value;

available = true;

notifyAll();

}

}

class Consumer extends Thread {

private CubbyHole cubbyhole;

private int number;

public Consumer(CubbyHole c, int number) {

cubbyhole = c;

this.number = number;

}

public void run() {

int value = 0;

for (int i = 0; i < 10; i++) {

value = cubbDFwlwQyhole.get();

System.out.println("消费者 #" + this.number+ " got: " + valDFwlwQue);

}

}

}

class Producer extends Thread {

private CubbyHole cubbyhole;

private int number;

public Producer(CubbyHole c, int number) {

cubbyhole = c;

this.number = number;

}

public void run() {

for (int i = 0; i < 10; i++) {

cubbyhole.put(i);

System.out.println("生产者 #" + this.number + " put: " + i);

try {

sleep((int)(Math.random() * 100));

} catch (InterruptedException e) { }

}

}

}

以上代码运行输出结果为:

消费者 #1 got: 0

生产者 #1 put: 0

生产者 #1 put: 1

消费者 #1 got: 1

生产者 #1 put: 2

消费者 #1 got: 2

生产者 #1 put: 3

消费者 #1 got: 3

生产者 #1 put: 4

消费者 #1 got: 4

生产者 #1 put: 5

消费者 #1 got: 5

生产者 #1 put: 6

消费者 #1 got: 6

生产者 #1 put: 7

消费者 #1 got: 7

生产者 #1 put: 8

消费者 #1 got: 8

生产者 #1 put: 9

消费者 #1 got: 9

以上就是Java如何通过线程解决生产者/消费者问题的详细内容,更多关于Java 解决生产者/消费者问题的资料请关注我们其它相关文章!


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:java jdk1.8 使用stream流进行list 分组归类操作
下一篇:Spring Cloud Gateway不同频率限流的解决方案(每分钟,每小时,每天)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~