java中ConcurrentLinkedQueue类

转自:http://blog.csdn.net/u010142437/article/details/22734857

一、类结构:

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue<E>
          java.util.concurrent.ConcurrentLinkedQueue<E>

类型参数:E - 在此 collection 中保持的元素类型所有已实现的接口:        Serializable, Iterable<E>, Collection<E>, Queue<E> 
二、概述:

public class ConcurrentLinkedQueue<E> extends AbstractQueue<E> implements Queue<E>, Serializable

一个基于链接节点的无界线程安全队列。此队列按照 FIFO(先进先出)原则对元素进行排序。队列的头部 是队列中时间最长的元素。队列的尾部 是队列中时间最短的元素。新的元素插入到队列的尾部,队列获取操作从队列头部获得元素。当多个线程共享访问一个公共 collection 时,ConcurrentLinkedQueue 是一个恰当的选择。此队列不允许使用 null 元素。

此实现采用了有效的“无等待 (wait-free)”算法,该算法基于 Maged M. Michael 和 Michael L. Scott 合著的 Simple, Fast, and Practical Non-Blocking and Blocking Concurrent Queue Algorithms 中描述的算法。

需要小心的是,与大多数 collection 不同,size 方法不是 一个固定时间操作。由于这些队列的异步特性,确定当前元素的数量需要遍历这些元素。

此类及其迭代器实现了 CollectionIterator 接口的所有可选 方法。

内存一致性效果:当存在其他并发 collection 时,将对象放入 ConcurrentLinkedQueue 之前的线程中的操作 happen-before 随后通过另一线程从 ConcurrentLinkedQueue 访问或移除该元素的操作。

此类是 JavaCollections Framework 的成员。

三、构造方法: 1、public ConcurrentLinkedQueue() 创建一个最初为空的 ConcurrentLinkedQueue

2、public ConcurrentLinkedQueue(Collection<? extends E> c)

创建一个最初包含给定 collection 元素的 ConcurrentLinkedQueue,按照此 collection 迭代器的遍历顺序来添加元素。

参数:
c - 最初包含的元素 collection
抛出:
NullPointerException - 如果指定 collection 或其任何元素为 null
四、方法详细:
1、public boolean add(E e)    将指定元素插入此队列的尾部。 

指定者:接口 Collection<E> 中的 add

指定者:接口 Queue<E> 中的 add、

覆盖:类 AbstractQueue<E> 中的 add

参数:o - 要添加的元素

返回:true(根据 Collection.add(E) 的规定)

抛出: NullPointerException - 如果指定元素为 null

2、public boolean offer(E e) 将指定元素插入此队列的尾部。

指定者:接口 Queue<E> 中的 offer

参数:e - 要添加的元素

返回:true(根据 Queue.offer(E) 的规定)

抛出: NullPointerException - 如果指定元素为 null

3、public E poll() 从接口 Queue 复制的描述 : 获取并移除此队列的头,如果此队列为空,则返回 null

指定者:接口 Queue<E> 中的 poll

返回:队列的头,如果此队列为空,则返回 null

4、public E peek() 从接口 Queue 复制的描述 :获取但不移除此队列的头;如果此队列为空,则返回 null

指定者:接口 Queue<E> 中的 peek

返回:此队列的头;如果此队列为空,则返回 null

5、public boolean isEmpty() 如果此队列不包含任何元素,则返回 true

指定者:接口 Collection<E> 中的 isEmpty

覆盖:类 AbstractCollection<E> 中的 isEmpty

返回:如果此队列不包含任何元素,则返回 true

6、public int size() 返回此队列中的元素数量。如果此队列包含的元素数大于 Integer.MAX_VALUE,则返回Integer.MAX_VALUE

需要小心的是,与大多数 collection 不同,此方法不是 一个固定时间操作。由于这些队列的异步特性,确定当前的元素数需要进行一次花费 O(n) 时间的遍历。

指定者:接口 Collection<E> 中的 size

指定者:类 AbstractCollection<E> 中的 size

返回:此队列中的元素数

7、public boolean contains(Object o) 如果此队列包含指定元素,则返回 true。更确切地讲,当且仅当此队列至少包含一个满足 o.equals(e) 的元素 e 时,返回 true

指定者:接口 Collection<E> 中的 contains

覆盖:类 AbstractCollection<E> 中的 contains

参数:o - 要检查是否包含于此队列的对象

返回:如果此队列包含指定元素,则返回 true

8、public boolean remove(Object o) 从队列中移除指定元素的单个实例(如果存在)。更确切地讲,如果此队列包含一个或多个满足 o.equals(e) 的元素 e,则移除一个这样的元素。如果此队列包含指定元素(或者此队列由于调用而发生更改),则返回 true

指定者:接口 Collection<E> 中的 remove

覆盖:类 AbstractCollection<E> 中的 remove

参数:o - 将从此队列中移除的元素(如果存在)

返回:如果此队列由于调用而发生更改,则返回 true

9、public Object[] toArray() 返回以恰当顺序包含此队列所有元素的数组。

由于此队列并不维护对返回数组的任何引用,因而它将是“安全的”。(换句话说,此方法必须分配一个新数组)。因此,调用者可以随意修改返回的数组。

此方法充当基于数组的 API 与基于 collection 的 API 之间的桥梁。

指定者:接口 Collection<E> 中的 toArray

覆盖:类 AbstractCollection<E> 中的 toArray

返回:包含此队列所有元素的数组

10、public <T> T[] toArray(T[] a) 返回以恰当顺序包含此队列所有元素的数组;返回数组的运行时类型是指定数组的运行时类型。如果指定的数组能容纳队列,则将该队列返回此处。否则,将分配一个具有指定数组的运行时类型和此队列大小的新数组。

如果指定的数组能容纳队列,并有剩余的空间(即数组的元素比队列多),那么会将紧接队列尾部的元素设置为null

像 toArray() 方法一样,此方法充当基于数组的 API 与基于 collection 的 API 之间的桥梁。更进一步说,此方法允许对输出数组的运行时类型进行精确控制,在某些情况下,这可以用来节省分配开销。

假定 x 是只包含字符串的一个已知队列。以下代码用来将该队列转储到一个新分配的 String 数组:

String[] y = x.toArray(new String[0]);

注意,toArray(new Object[0]) 和 toArray() 在功能上是相同的。

指定者:接口 Collection<E> 中的 toArray

覆盖:类 AbstractCollection<E> 中的 toArray

参数:a - 将用来存储队列元素的数组(如果该数组足够大);否则,将为此分配一个具有相同运行时类型的新数组

返回:包含此队列所有元素的数组

抛出: ArrayStoreException - 如果指定数组的运行时类型不是此队列中每个元素的运行时类型的超类型

NullPointerException - 如果指定数组为 null

11、public Iterator<E> iterator() 返回在此队列元素上以恰当顺序进行迭代的迭代器。返回的迭代器是一个“弱一致”迭代器,它不会抛出 ConcurrentModificationException,并且可保证遍历迭代器构造时存在的元素,此外还可能(但并不保证)反映构造后的所有修改。

指定者:接口 Iterable<E> 中的 iterator

指定者:接口 Collection<E> 中的 iterator

指定者:类 AbstractCollection<E> 中的 iterator

返回:在此队列元素上以恰当顺序进行迭代的迭代器

时间: 2024-08-10 15:01:40

java中ConcurrentLinkedQueue类的相关文章

关于java同步包中ConcurrentLinkedQueue类的深入分析与理解

一,官方描述 一个基于连接节点的无界线程安全队列.这个队列的顺序是先进先出.队列头部的元素是留在队列中时间最长的,队列尾部的元素是留在队列中时间最短的.新元素被插入到元素的尾部,队列从队列的头部检索元素.当许多线程共享访问同一个集合时,这个类是不二选择.这个队列不允许有null元素. 这个实现基于一种被描述为简单,快速,实用的非阻塞和阻塞公布队列算法而提供的一种有效的空闲等待算法. 注意,不像大多数集合,size方法的操作不是常量时间的,由于是异步队列,决定了元素的数量需要遍历真个元素集. 这个

hadoop中Text类 与 java中String类的区别

hadoop 中 的Text类与java中的String类感觉上用法是相似的,但两者在编码格式和访问方式上还是有些差别的,要说明这个问题,首先得了解几个概念: 字符集: 是一个系统支持的所有抽象字符的集合.字符是各种文字和符号的总称,包括各国家文字.标点符号.图形符号.数字等.例如 unicode就是一个字符集,它的目标是涵盖世界上所有国家的文字和符号: 字符编码:是一套法则,使用该法则能够对自然语言的字符的一个集合(如字母表或音节表),与其他东西的一个集合(如号码或电脉冲)进行配对.即在符号集

Java中String类学习总结

java中String类的使用频率非常高,本人在学习此模块时,认为下列几点知识值得注意: 一.String是不可变对象 java.lang.String类使用了final修饰,不能被继承.Java程序中的所有字面值,即双引号括起的字符串,如"abc",都是作为String类的实例实现的.String是常量,其对象一旦构造就不能再被改变.换句话说,String对象是不可变的,每一个看起来会修改String值的方法,实际上都是创造了一个全新的String对象,以包含修改后的字符串内容.而最

【转载】Java中String类的方法及说明

转载自:http://www.cnblogs.com/YSO1983/archive/2009/12/07/1618564.html String : 字符串类型 一.构造函数     String(byte[ ] bytes):通过byte数组构造字符串对象.     String(char[ ] value):通过char数组构造字符串对象.     String(Sting original):构造一个original的副本.即:拷贝一个original.     String(Strin

java中Color类的简单总结

java中Color类的简单总结 1.颜色的常识 任何颜色都是由三原色组成(RGB),JAVA中支持224为彩色,即红绿蓝分量取值 介于0-255之间(8位表示) 2.Color类中的常量 public final static Color black = new Color(0,0,0); public final static Color bule = new Color(0,0,255); . . 有很多这样的常量,可供我们直接类名去调用而不需要去实例化. 3.Color中的构造函数 pu

Java中Arrays类的两个方法:deepEquals和equals

deepEquals和equals是Java中Arrays类的两个静态方法,可是它们之间有什么样的区别呢? 代码一. import java.util.Arrays; public class Test { public static void main(String[] args) { String[][] name1 = {{ "G","a","o" },{ "H","u","a",

Java中Properties类

Java中Properties类简介 知识学而不用,就等于没用,到真正用到的时候还得重新再学. Properties类继承自Hashtable,如下: 它主要用于读取Java的配置文件,由于配置文件中的很多变量时经常改变的,通过这个类可以让用户脱离程序本身去修改相关的变量配置.在Java中,其配置文件常为.properties文件,格式为文本文件,内容的格式为“键=值”的格式,#打头的是注释行,Properties会忽略注释.允许只有key没有value,没有value时,value会被set成

Java中Integer类的方法

字段摘要 static int MAX_VALUE              保持 int 类型的最大值的常量可取的值为 231-1. static int MIN_VALUE              保持 int 类型的最小值的常量可取的值为 -231. static int SIZE              以二进制补码形式表示 int 值的位数. static Class<Integer> TYPE              表示基本类型 int 的 Class 实例. 构造方法摘要

java中String类小结

构建一个字符串 1.用字符串直接量: String message = new String("Welcome to java"); 2.用字符串直接量: String message = "Welcome to java"; 3.用字符数组 Char[] charArray = {'m', 'y'}; String message = new String(charArray); 不可变字符与限定字符串 String对象是不可变的,内容不能改变 java虚拟机为了