文档章节

阻塞队列 BlockingQueue

Kevin-air
 Kevin-air
发布于 2014/01/07 21:03
字数 554
阅读 331
收藏 2

java.util.concurrent.BlockingQueue 接口代表了线程安全的队列。

BlockingQueue的使用

一个BlockingQueue的典型使用是一个线程不断生产对象往队列里放,另一个线程往队列里取对象进行消费。

生产线程会保持一致产生新的对象并且插入到队列中,直到队列到达了它的存储上限,生产线程再往队列插入时会发现阻塞,并且一直保持阻塞直到消费线程从队列中取出一个对象。

消费线程会保持从队列中取出对象并且进行处理,如果消费线程试图从一个空的队列中取出对象,那么消费线程将会阻塞直到生产线程往队列中放入了新的对象。

BlockingQueue的方法

BlockingQueue由4中不同的方法来添加,删除和检测。每组方法有不同的特点泳衣满足不能立即执行响应请求的操作。

操作 抛出异常 返回操作结果 阻塞 超时
插入 add(o) offer(o) put(o) offer(o,timeout,timeunit)
删除 remove(o) poll(o) take(o) poll(timeout,timeunit)
检测element(o) peek(o)


1.抛出异常:如果对应方法没有立即执行则抛出异常。

2.返回操作结果:如果对应方法立即执行返回true,否则则返回false(超出队列容量)。

3.阻塞:如果对应方法无法立即执行,则将阻塞等待直到方法完成。

4.超时:如果对应方法无法立即执行,则会一直等待但不超过给定的超时范围,返回相应的结果。

BlockingQueue的实现类

ArrayBlockingQueue

DelayQueue

LinkedBlockingDeque

PriorityBlockingQueue

SynchronousQueue

BlockingQueue的示例

// 文章开头生产与消费的示例
public class BlockingQueueExample {

    public static void main(String[] args) throws Exception {

        BlockingQueue queue = new ArrayBlockingQueue(1024);

        Producer producer = new Producer(queue);
        Consumer consumer = new Consumer(queue);

        new Thread(producer).start();
        new Thread(consumer).start();

        Thread.sleep(4000);
    }
}

// 生产者
public class Producer implements Runnable{

    protected BlockingQueue queue = null;

    public Producer(BlockingQueue queue) {
        this.queue = queue;
    }

    public void run() {
        try {
            queue.put("1");
            Thread.sleep(1000);
            queue.put("2");
            Thread.sleep(1000);
            queue.put("3");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

// 消费者
public class Consumer implements Runnable{

    protected BlockingQueue queue = null;

    public Consumer(BlockingQueue queue) {
        this.queue = queue;
    }

    public void run() {
        try {
            System.out.println(queue.take());
            System.out.println(queue.take());
            System.out.println(queue.take());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}


© 著作权归作者所有

共有 人打赏支持
Kevin-air
粉丝 13
博文 73
码字总数 26587
作品 0
深圳
并发编程 – Concurrent 用户指南( 一)

1. java.util.concurrent – Java 并发工具包 Java 5 添加了一个新的包到 Java 平台,java.util.concurrent 包。这个包包含有一系列能够让 Java 的并发编程变得更加简单轻松的类。在这个包被...

余平的余_余平的平
2017/09/07
0
0
Java阻塞队列_BlockingQueue

Java阻塞队列_BlockingQueue 以上是BlockingQueue所有的方法。。 add(anObject):把anObject加到BlockingQueue里,如果BlockingQueue可以容纳,则返回true,否则抛出异常。 offer(anObject):...

秋风醉了
2014/08/07
127
0
Java多线程-工具篇-BlockingQueue

前言: 在新增的Concurrent包中,BlockingQueue很好的解决了多线程中,如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类,为我们快速搭建高质量的多线程程序带来极大的便利...

空云万里晴
2016/06/16
54
0
[Java并发编程实战] 阻塞队列 BlockingQueue(含代码,生产者-消费者模型)

见贤思齐焉,见不贤而内自省也。—《论语》 Java5.0 增加了两种新的容器类型,它们是指:Queue 和 BlockingQueue。Queue 用来临时保存一组等待处理的元素。BlockingQueue 扩张了 Queue 接口,...

seaicelin
06/02
0
0
Java多线程-工具篇-BlockingQueue

前言: 在新增的Concurrent包中,BlockingQueue很好的解决了多线程中,如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类,为我们快速搭建高质量的多线程程序带来极大的便利...

vshcxl
2016/12/12
5
1

没有更多内容

加载失败,请刷新页面

加载更多

CentOS7防火墙firewalld操作

firewalld Linux上新用的防火墙软件,跟iptables差不多的工具。 firewall-cmd 是 firewalld 的字符界面管理工具,firewalld是CentOS7的一大特性,最大的好处有两个:支持动态更新,不用重启服...

dingdayu
今天
1
0
关于组件化的最初步

一个工程可能会有多个版本,有国际版、国内版、还有针对各种不同的渠道化的打包版本、这个属于我们日常经常见到的打包差异化版本需求。 而对于工程的开发,比如以前的公司,分成了有三大块业...

DannyCoder
今天
2
0
Spring的Resttemplate发送带header的post请求

private HttpHeaders getJsonHeader() { HttpHeaders headers = new HttpHeaders(); MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8"); ......

qiang123
昨天
3
0
Spring Cloud Gateway 之 Only one connection receive subscriber allowed

都说Spring Cloud Gateway好,我也来试试,可是配置了总是报下面这个错误: java.lang.IllegalStateException: Only one connection receive subscriber allowed. 困扰了我几天的问题,原来...

ThinkGem
昨天
31
0
学习设计模式——观察者模式

1. 认识观察者模式 1. 定义:定义对象之间一种一对多的依赖关系,当一个对象状态发生变化时,依赖该对象的其他对象都会得到通知并进行相应的变化。 2. 组织结构: Subject:目标对象类,会被...

江左煤郎
昨天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部