`
qing_gee
  • 浏览: 121520 次
  • 性别: Icon_minigender_1
  • 来自: 河南
社区版块
存档分类
最新评论

java中的阻塞队列

    博客分类:
  • Java
阅读更多

今天开始在学习Java的阻塞队列,所以先进行一些了解

阻塞队列提供了可阻塞的put和take方法,以及支持定时的offer和poll方法。如果队列已经满了,那么put方法会阻塞到有可用空间;如果队列为空,take方法会一直阻塞到有可用元素。阻塞队列非常实用于生产者和消费者模式,当有数据生成时,生产者把数据放入队列,当消费者需要数据时,从队列中进行获取。而生产者不需要知道消费者的状态,同样消费者也不需要知道生产者的状态。当然消费者和生产者是相对的,假如生产者的速率大于消费者,那么当队列满了的时候,生产者可以转为消费者,将队列中的数据取出进行消费者的处理,这个道理同样适用于消费者。

下面来介绍阻塞队列的四种处理方式:

1.抛出异常,当调用add(e)方法将元素添加到队列中时,如果队列已经满了,则会抛出IllegalStateException;当调用remove(e)方法将元素从队列中移除时,如果指定的元素不存在时,则会抛出NullPointerException。当调用element()方法获取队列的头部时,如果队列为空,则会抛出NullPointerException。

 

2.特殊值,当调用offer(e)方法将元素插入到队列中时,如果该元素已经添加到该队列,则返回true,否则返回false;当调用poll()方法移除队列的头部时,返回被移除的队列头部;当调用peek()方法获取队列头部时,返回队列头部,如果队列为空,则返回null。

3.阻塞,即如前文介绍的put和take方法。

4.超时,当调用offer(e,time,unit)方法将指定元素插入到队列中,在插入之前等待以unit为单位的time超时时间,如果成功,返回true,如果超时,则返回false;当调用poll(time,unit)方法返回并且移除队列头部时,等待以unit为单位的time时间内的可用元素,如果成功,返回队列头部,如果超时,返回false。

 

接下来介绍几种常见的队列类型:

1.LinkedBlockingQueue:基于LinkedList的FIFO(first input,first out)的队列。

2.ArrayBlockingQueue:基于ArrayList的FIFO队列。

3.ProrityBlockingQueue:按照优先级排序的队列,可以按照元素的自然顺序或者元素实现的Comparable方式排序。

4.SynchronousQueue:实际上不是一个真正的队列,因为不会为队列中的元素进行维护,而它维护的是一组线程,这些线程在等待着把元素加入或者移除队列,它会直接将元素从生产者交付给消费者,而不需要一个中间件,从而会降低数据从生产者到消费者之间的延迟,但是该队列只适用于有足够多的消费者,并且总有一个消费者准备好获取交付的元素时的场合。

 

一些队列的基础知识介绍就到此,接下来会进入到更深入的了解方式。

0
0
分享到:
评论
2 楼 qing_gee 2014-06-16  
jingyemingyue 写道
哥们学习的是哪本书啊?

java并发编程开发然后参考API
1 楼 jingyemingyue 2014-06-15  
哥们学习的是哪本书啊?

相关推荐

    剖析Java中阻塞队列的实现原理及应用场景

    阻塞队列的核心特性在于当队列为空时,尝试获取元素的线程会被阻塞,直到队列中有元素可用;同样,当队列满时,尝试添加元素的线程也会被阻塞,直到队列有空间。这种机制避免了额外的同步和唤醒操作,简化了编程模型...

    java模拟阻塞队列

    Java中的阻塞队列是一种基于同步原语的高级数据结构,它在多线程编程中扮演着重要角色,尤其在并发处理和优化系统资源利用率方面。阻塞队列结合了队列的数据结构与线程同步机制,使得生产者可以在队列满时被阻塞,而...

    阻塞队列阻塞队列阻塞队列

    在Java编程语言中,阻塞队列是一种线程安全的数据结构,它在多线程并发控制中发挥着重要作用。阻塞队列的核心特性是当队列为空时,尝试获取元素的线程会被阻塞,直到其他线程添加元素;同样,当队列满时,试图插入...

    java 中 阻塞队列BlockingQueue详解及实例

    Java中的阻塞队列BlockingQueue是一种并发编程中常用的工具,它实现了线程间的同步和通信。阻塞队列的核心特性在于当队列为空时,尝试获取元素的线程会被阻塞,直到其他线程添加元素;当队列满时,尝试添加元素的...

    支持多线程和泛型的阻塞队列

    阻塞队列是一种在多线程编程中广泛使用的并发数据结构,它在计算机科学和编程领域,特别是Java和C++等面向对象语言中扮演着重要角色。标题中的“支持多线程和泛型的阻塞队列”意味着我们讨论的是一个能够同时处理多...

    Java实现简单的阻塞队列2种方式

    在Java编程中,阻塞队列是一种特殊类型的并发数据结构,它在多线程环境中的应用广泛,主要用于线程间的协作通信。阻塞队列在队列满时会阻止生产者线程添加元素,在队列空时会阻止消费者线程取出元素,直到条件满足...

    java线程聊天室(阻塞队列实现)

    生产者线程(如用户发送消息的线程)将消息放入阻塞队列,而消费者线程(如处理和分发消息的线程)从队列中取出消息。通过这种方式,生产者和消费者可以异步工作,提高系统吞吐量。 登录机制是聊天室的重要组成部分...

    java学习(基于Java阻塞队列的搜索实例).pdf

    通过以上分析,我们了解到基于Java阻塞队列的搜索实例利用了Java并发API的强大功能来实现多线程间的高效协作,从而完成复杂的文件搜索任务。在多线程编程实践中,理解阻塞队列的工作原理和正确使用它们是关键的一步...

    java阻塞队列实现原理及实例解析.docx

    总结来说,Java阻塞队列是一种强大的并发工具,它通过自动阻塞和唤醒线程来实现线程间的同步,简化了多线程编程的复杂性。在Java `java.util.concurrent`包中提供了多种优化的阻塞队列实现,适用于不同的并发需求。...

    14-阻塞队列BlockingQueue实战及其原理分析二.pdf

    BlockingQueue继承了Queue接口,是Java 5中加入的。 BlockingQueue常用方法示例: 1. add(E e):添加一个元素,如果队列满了,就会抛出异常。 2. offer(E e):添加一个元素,如果队列满了,返回false。 3. offer(E...

    并发-线程池和阻塞队列.pdf

    Java中的ArrayBlockingQueue和LinkedBlockingQueue都是典型的阻塞队列实现。 阻塞队列为线程间通信提供了便捷的机制,可以用来协调多个线程的运行,防止多线程直接访问共享资源导致的并发问题。例如,生产者-消费者...

    阻塞队列实现生产者消费者模式Java开发Java经验技巧共

    在Java开发中,生产者消费者模式是一种常见的多线程设计模式,它允许生产者线程创建数据并放入队列,而消费者线程则从队列中取出并处理这些数据,两者之间无需直接交互,有效解耦了系统组件。在这个场景中,阻塞队列...

    Java中的阻塞队列详细介绍

    Java中的阻塞队列是一种特殊的队列数据结构,它在多线程环境下广泛应用于生产者-消费者模式。阻塞队列的主要特点在于当队列为空时,试图从中取出元素的消费者线程会被阻塞,直到有其他生产者线程添加元素;同样,当...

    java阻塞队列实现原理及实例解析

    Java阻塞队列实现原理及实例解析 Java阻塞队列是一种特殊的队列,它能够在队列为空或满时阻塞线程,使得线程之间能够更好地协作和通信。阻塞队列的实现原理是基于锁机制和条件变量机制的,通过wait和notify方法来...

    并发-线程池和阻塞队列

    例如,当一个新任务被提交到线程池时,它会被放入阻塞队列中,然后由线程池中的工作线程从队列中取出并执行。这种方式避免了频繁的线程创建和销毁,减少了系统的开销,并通过合理配置线程池参数,可以更好地平衡系统...

    BlockingQueue(阻塞队列)详解

    - **定义**:阻塞队列是一种特殊的队列,除了具有队列的基本特性外,还提供了额外的阻塞行为,即当队列空时,从队列中获取元素的操作将会阻塞,等待队列变得非空;当队列满时,向队列插入元素的操作也会阻塞,等待...

    消息分发框架(基于JAVA阻塞队列实现、 生产者消费者模型)

    Java阻塞队列是并发编程中的重要工具,它是一个线程安全的数据结构,提供了在生产者和消费者之间同步共享数据的方法。阻塞队列在满时会阻止生产者继续插入元素,在空时会阻止消费者进行消费。这种机制可以防止数据...

    Java并发编程(21)并发新特性-阻塞队列和阻塞栈(含代

    在Java并发编程中,阻塞队列和阻塞栈是两个重要的并发数据结构,它们在多线程环境下的高效通信和资源管理中扮演着至关重要的角色。这些数据结构源自Java的并发包`java.util.concurrent`,是实现并发设计模式如生产者...

    生产者/消费者模式 阻塞队列 LinkedBlockingQueue

    在Java中,阻塞队列(BlockingQueue)是一个很好的实现生产者/消费者模式的工具,而LinkedBlockingQueue则是Java并发包(java.util.concurrent)中提供的一个具体实现。 LinkedBlockingQueue是一个基于链表结构的...

Global site tag (gtag.js) - Google Analytics