Java生产者和消费者例子_动力节点Java学院整理

网友投稿 204 2023-05-12


Java生产者和消费者例子_动力节点Java学院整理

生产者-消费者(producer-consumer)问题,也称作有界缓冲区(bounded-buffer)问题,两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者,用于将消息放入缓冲区;另外一个是消费者,用于从缓冲区中取出消息。问题出现在当缓冲区已经满了,而此时生产者还想向其中放入一个新的数据项的情形,其解决方法是让生产者此时进行休眠,等待消费者从缓冲区中取走了一个或者多个数据后再去唤醒它。同样地,当缓冲区已经空了,而消费者还想去取消息,此时也可以让消费者进行休眠,等待生产者放入一个或者多个数据时再唤醒它。

一,首先定义公共资源类,其中的变量number是保存的公共数据。

并且定义两个方法,增加number的值和减少number的值。由于多线程的原因,必须加上synchronized关键字,注意while判断的条件。

java代码

二,分别定义生产

/**

* 公共资源类

*/

public class PublicResource {

private int number = 0;

/**

* 增加公共资源

*/

public synchronized void increace() {

while (number != 0) {

try {

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

number++;

System.out.println(number);

notify();

}

/**

* 减少公共资源

*/

pukvthWJblic synchronized void decreace() {

while (number == 0) {

try {

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

number--;

System.out.println(number);

notify();

}

}

者线程和消费者线程,并模拟多次生产和消费,即增加和减少公共资源的number值

Java代码

/**

* 生产者线程,负责生产公共资源

*/

public class ProducerThread implements Runnable {

private PublicResource resource;

public ProducerThread(PublicResource resource) {

this.resource = resource;

}

@Override

public void run() {

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

try {

Thread.sleep((long) (Math.random() * 1000));

} catch (InterruptedException e) {

e.printStackTrace();

}

resource.increace();

}

}

}

/**

* 消费者线程,负责消费公共资源

*/

public class ConsumerThread implements Runnable {

private PublicResource resource;

public ConsumerThread(PublicResource resource) {

this.resource = resource;

}

@Override

public void run() {

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

try {

Thread.sleep((long) (Math.random() * 1000));

} catch (InterruptedException e) {

e.printStackTrace();

}

resource.decreace();

}

}

}

三,模拟多个生产者和消费者操作公共资源的情形,结果须保证是在允许的范围内。

Java代码

public class ProducerConsumerTest {

public static void main(String[] args) {

PublicResource resource = new PublicResource();

new Thread(new ProducerThread(resource)).start();

new Thread(new ConsumerThread(resource)).start();

new Thread(new ProducerThread(resource)).start();

new Thread(new ConsumerThread(resource)).start();

new Thread(new ProducerThread(resource)).start();

new Thread(new ConsumerThread(resource)).start();

}

}

以上所述是给大家介绍的Java生产者和消费者例子,希望对大家有所帮助,如果大家有任何疑问请给我留言,会及时回复大家的。在此也非常感谢大家对我们网站的支持!


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

上一篇:img 加载网络图片失败 显示默认图片的方法
下一篇:详解spring中使用solr的代码实现
相关文章

 发表评论

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