BlockingQueue简单使用

本文主要是介绍BlockingQueue简单使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

• 明确BlockingQueue的作用以及使用场景；
• 悉知BlockingQueue的基本使用

1、BlockingQueue一般用于排队的列子，比如多线程的批量下载或者上传，有效控制队列高效执行，
2、BlockingQueue的实例化以及怎么去使用

   //实例化BlockingQueue并指定队列的容量为10 ，超出10将会阻塞，直到basket.take()消费才会继续添加进队列中去private BlockingQueue<Apple> basket= new LinkedBlockingQueue<Apple>(10);//加入队列basket.put(apple);//从队列中取出 线程任务进行消费basket.take()

写一个demo记录BlockingQueue的简单使用

• 首先定义一个队列用于装我们需要执行的动作

public class Basket {/*** 篮子的容量为10个*/private BlockingQueue<Apple> basket= new LinkedBlockingQueue<Apple>(10);/*** 装进篮子** @param apple*/public void produce(Apple apple){try {//添加元素到队列，如果队列已满,线程进入等待，直到有空间继续生产basket.put(apple);//添加元素到队列，如果队列已满，抛出IllegalStateException异常，退出生产模式
//        queue.add(bean);//添加元素到队列，如果队列已满或者说添加失败，返回false，否则返回true，继续生产
//        queue.offer(bean);//添加元素到队列，如果队列已满，就等待指定时间，如果添加成功就返回true，否则false，继续生产
//        queue.offer(bean,5, TimeUnit.SECONDS);} catch (InterruptedException e) {e.printStackTrace();}}/*** 消费** @return*/public  Apple consume(){try {//检索并移除队列头部元素，如果队列为空,线程进入等待，直到有新的数据加入继续消费Apple apple = basket.take();//检索并删除队列头部元素，如果队列为空，抛出异常，退出消费模式
//        Apple bean = queue.remove();//检索并删除队列头部元素，如果队列为空，返回false，否则返回true，继续消费
//        Apple bean = queue.poll();//检索并删除队列头部元素，如果队列为空，则等待指定时间，成功返回true，否则返回false，继续消费
//        Apple bean = queue.poll(3, TimeUnit.SECONDS);return apple ;} catch (InterruptedException e) {e.printStackTrace();}return null;}
}

• 创建任务者 队列.put(Producer )

/*** 生产者*/
public class Producer implements Runnable {private String produce= "4234343 ";private Basket basket;public Producer(Basket basket){this.basket=basket;}@Overridepublic void run() {try {for (int i = 0; ; i++) {Apple bean = new Apple("苹果" + i + "号");Log.e("======produce=======", produce + "正在生产苹果 " + bean);basket.produce(bean);Log.e("======produce=======", produce + "生产苹果 " + bean + " 结束----------------");Thread.sleep(1000);}} catch (InterruptedException e) {e.printStackTrace();}}
}

• 消费者 队列.take();

Basket basket;public Consumeer (Basket basket){this.basket=basket;}int i;@Overridepublic void run() {while (true){try {Thread.sleep(20*1000);basket.consume();i++;Log.d("=========take======","i="+i);} catch (InterruptedException e) {e.printStackTrace();}}}
}

• 消费对象

public class Apple {String name;public Apple(String name) {this.name = name;}public String getName() {return name;}public void setName(String name) {this.name = name;}@Overridepublic String toString() {return name;}
}

最后在activity中调用

        Basket basket=new Basket();//生产者Producer producer=new Producer(basket);//消费者Consumeer consumeer=new Consumeer(basket);ExecutorService service = Executors.newFixedThreadPool(5);/*线程池  执行生产*/service.execute(producer);/*线程池  执行开始消费*/service.execute(consumeer);

这篇关于BlockingQueue简单使用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---