8.1.1使用BlockingQueue和ArrayBlockingQueue

使用BlockingQueue来实现产生都与消费者的例子，比起前面第三章的用法会更加简单，因为它不需要去解决同步问题。下面的例子使用BlockingQueue和ArrayBlockingQueue实现生产者的消费者的例子。

package com.owen.thread.chapter8;import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class PC
{public static void main(String[] args){final BlockingQueue<Character> bq;bq = new ArrayBlockingQueue<Character>(26);final ExecutorService executor = Executors.newFixedThreadPool(2);Runnable producer = () -> {for (char ch = 'A'; ch <= 'Z'; ch++){try{bq.put(ch);System.out.printf("%c produced by " + "producer.%n", ch);} catch (InterruptedException ie){}}};executor.execute(producer);Runnable consumer = () -> {char ch = '\0';do{try{ch = bq.take();System.out.printf("%c consumed by " + "consumer.%n", ch);} catch (InterruptedException ie){}} while (ch != 'Z');executor.shutdownNow();};executor.execute(consumer);}
}

上面的例子中，使用BlockingQueue()的put()和take()方法，分别代表，在阻塞的队列中放入一个对象，和在阻塞的队列中移除一个对象。当没有空间放入一个对象时，put()方法会阻塞；当队列为空时，take()会阻塞。

BlockingQueue确保一个字母在生产之前不会被消费，这个应用会有输出提示。例子，执行这个程序会得到如下的输出：

A produced by producer.
B produced by producer.
A consumed by consumer.
B consumed by consumer.
C consumed by consumer.
C produced by producer.
••••••

8.1.1使用BlockingQueue和ArrayBlockingQueue相关推荐

java多线程-阻塞队列BlockingQueue
大纲 BlockingQueue接口 ArrayBlockingQueue 一.BlockingQueue接口 public interface BlockingQueue<E> exte ...
从一个故障说说Java的三个BlockingQueue
最近出了个故障,排查的时候耗费了很长的时间,回顾整个排查过程,经验主义在这里起了不好的作用,直接导致了整个故障排查的时间非常长,这个故障的根本原因在于BlockingQueue用的有问题,顺带展开说说 ...
多线程：线程池里的队列BlockingQueue
runnableTaskQueue(任务队列):用于保存等待执行的任务的阻塞队列. 可以选择以下几个阻塞队列: BlockingQueue的几个注意点 [1]BlockingQueue 可以是限定容量 ...
BlockingQueue常用方法add、off、put、take、poll使用说明
1.BlockingQueue的定义首先将BlockingQueue提供的方法的含义解释如下: import java.util.Collection; import java.util.Queue ...
【学习笔记】抽象队列同步器AQS应用之BlockingQueue详解
文章目录什么是AQS框架 Aqs核心源码基于aqs实现的锁 BlockingQueue ArrayBlockingQueue LinkedBlockingQueue DelayQueue Bloc ...
19.并发容器之BlockingQueue
1. BlockingQueue简介在实际编程中,会经常使用到JDK中Collection集合框架中的各种容器类如实现List,Map,Queue接口的容器类,但是这些容器类基本上不是线程安全的,除 ...
JUC阻塞队列BlockingQueue讲解
概述阻塞队列有两个特性: 阻塞:当队列为空时,会阻塞队列弹出操作,直到队列不为空.当队列满了时,会阻塞入队操作,直到队列不满. 队列:FIFO,先进先出. 接口:java.util.concurre ...
Java并发编程-BlockingQueue阻塞队列
BlockingQueue阻塞队列 1.BlockingQueue介绍 1.1.引言: 1.2.阻塞队列介绍: 1.3.阻塞队列的用处: 1.4.接口架构图 2.BlockingQueue核心方法 3 ...
Java并发编程：4种线程池和缓冲队列BlockingQueue
一. 线程池简介 1. 线程池的概念: 线程池就是首先创建一些线程,它们的集合称为线程池.使用线程池可以很好地提高性能,线程池在系统启动时即创建大量空闲的线程,程序将一个任务传给线程池,线程池就会启动 ...
Java高并发BlockingQueue重要的实现类
ArrayBlockingQueue 有界的阻塞队列,内部是一个数组,有边界的意思是:容量是有限的,必须进行初始化,指定它的容量大小,以先进先出的方式存储数据,最新插入的在对尾,最先移除的对象在头部. ...

8.1.1使用BlockingQueue和ArrayBlockingQueue

8.1.1使用BlockingQueue和ArrayBlockingQueue相关推荐

最新文章

热门文章