这个是消费者类
import java.util.concurrent.BlockingQueue;
public class ConsumerBlockingQueue extends Thread {
private final BlockingQueue<Integer> queue;
private final String name;
public ConsumerBlockingQueue(BlockingQueue<Integer> q, String name)
{
queue=q;
this.name=name;
}
public void run() {
// TODO Auto-generated method stub
try
{
while(true)
{
consume(queue.take());
try
{
sleep(800);// 将消费者的睡眠时间设置得比生产者小是为了演示当产品列表为空的情形
}catch(Exception e){
e.printStackTrace();
}
}
}catch(Exception e){
e.printStackTrace();
}
}
private void consume(int i)
{
System.out.println(name+" consume "+i);
}
}
这个是生产者类
public class ProducerBlockingQueue extends Thread{
private final BlockingQueue<Integer> queue;
private final String name;
private static int i=0;
public ProducerBlockingQueue(BlockingQueue<Integer> q, String name)
{
queue=q;
this.name=name;
}
public void run() {
// TODO Auto-generated method stub
try
{
while(true)
{
queue.add(produce());
try
{
sleep(1000);
}catch(Exception e){
e.printStackTrace();
}
}
}catch(Exception e){
e.printStackTrace();
}
}
private int produce()
{
System.out.println(name+" producing "+i);
return i++;
}
}
我们定义一个Queue来实现BlockingQueue
import java.util.*;
import java.util.Collection;
import java.util.Iterator;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
public class Queue implements BlockingQueue {
private List list=new ArrayList();
public boolean add(Object o) {
// TODO Auto-generated method stub
list.add(o);
return true;
}
public Object take() throws InterruptedException {
// TODO Auto-generated method stub
while(isEmpty()){}
return list.remove(0);
}
public boolean isEmpty() {
// TODO Auto-generated method stub
return list.isEmpty();
}
// 当然这个类还有其他的方法需要实现,为了清楚起见,我把使用默认实现的方法都去掉了。
}
下面我们来测试下
import java.util.concurrent.BlockingQueue;
public class Test {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
BlockingQueue<Integer> q=new Queue();
ProducerBlockingQueue p=new ProducerBlockingQueue(q,"p");
ProducerBlockingQueue p1=new ProducerBlockingQueue(q,"p1");
ConsumerBlockingQueue c=new ConsumerBlockingQueue(q,"c");
ConsumerBlockingQueue c1=new ConsumerBlockingQueue(q,"c1");
p.start();
p1.start();
c.start();
c1.start();
}
}
看到没有,就这么简单,以很少的逻辑代码实现了消费者与生产者功能,当然你还可以对他进行扩充,让他更加完善。
分享到:
相关推荐
主要介绍了java并发学习之BlockingQueue实现生产者消费者详解,具有一定参考价值,需要的朋友可以了解下。
主要介绍了Java多线程Queue、BlockingQueue和使用BlockingQueue实现生产消费者模型方法解析,涉及queue,BlockingQueue等有关内容,具有一定参考价值,需要的朋友可以参考。
BlockingQueue java 的工具类,初次要用于消费者,生产者的同步问题。
主要介绍了Java多线程 BlockingQueue实现生产者消费者模型详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
java 多线程 生产者消费者模式,多个生产者对多个消费者,使用jdk 线程池及 BlockingQueue实现,解决了待生产的任务生产完成后,正常终止所有线程,避免线程(特别是消费者线程)因阻塞而无限等待的情况。源码中还简单...
这个demo主要讲解了BlockingQueue的使用希望可以帮户需要的同学.
源码:BlockingQueue实现生产者消费者模式→ 输出结果截图 1. Queue接口 – 队列 public interface Queue extends Collection Collection的子接口,表示队列FIFO(First In First Out) 常用方法: (1)抛出异常...
线程----BlockingQueue 的介绍说明
在新增的Concurrent包中,BlockingQueue很好的解决了多线程中,如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类,为我们快速搭建高质量的多线程程序带来极大的便利。本文详细介绍了BlockingQueue...
类似java BlockingQueue,C++写的,支持Windows与Linux。
在新增的Concurrent包中,BlockingQueue很好的解决了多线程中,如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类,为我们快速搭建高质量的多线程程序带来极大的便利。本文简要介绍下BlockingQueue...
简单实现BlockingQueue,BlockingQueue源码详解
BlockingQueue是一种特殊的Queue,若BlockingQueue是空的,从BlockingQueue取东西的操作将会被阻断进入等待状态直到BlocingkQueue进了新货才会被唤醒,下面是用BlockingQueue来实现Producer和Consumer的例子
定义全局线程池,将用户的请求放入自定义队列中,排队等候线程调用,等待超时则自动取消该任务,实现超时可取消的异步任务
本篇文章小编为大家介绍,基于java中BlockingQueue的使用介绍。需要的朋友参考下
14-阻塞队列BlockingQueue实战及其原理分析二.pdf
BlockingQueue支持两个附加操作的Queue:1)当Queue为空时,获取元素线程被阻塞直到Queue变为非空;2)当Queue满时,添加元素线程被阻塞直到Queue不满。BlockingQueue不允许元素为null,...常用于生产者消费者模式。
我们知道 BlockingQueue 是一个 FIFO 队列,生产者(Producer)往队列里发布(publish)一项事件(或称之为“消息”也可以)时,消费者(Consumer)能获得通知;如果没有事件时,消费者被堵塞,直到生产者发布了新的事件。 ...
我们知道 BlockingQueue 是一个 FIFO 队列,生产者(Producer)往队列里发布(publish)一项事件(或称之为“消息”也可以)时,消费者(Consumer)能获得通知;如果没有事件时,消费者被堵塞,直到生产者发布了新的事件。 ...
生产者消费者在 Java 中实现生产者 - 消费者问题。 基于此处介绍的示例: :