E
- このコレクション内に保持される要素の型public class ConcurrentLinkedQueue<E> extends AbstractQueue<E> implements Queue<E>, Serializable
ConcurrentLinkedQueue
は選択肢として適切です。大半のコレクション実装と同様、このクラスはnull
要素の使用を許容しません。
この実装では、効率のよい非ブロックのアルゴリズムが使用されます。このアルゴリズムの参考資料:「Simple, Fast, and Practical Non-Blocking and Blocking Concurrent Queue Algorithms」(Maged M. Michael、Michael L. Scott)
イテレータは弱一貫性を持ち、ある時点での、またはイテレータの作成以降のキューの状態を反映する要素を返します。これらはConcurrentModificationException
をスローせず、ほかのオペレーションとの並行処理が可能です。イテレータの作成以降にキューに含まれた要素が1回だけ返されます。
大半のコレクションとは異なり、size
メソッドは一定時間のオペレーションではないことに留意してください。これらのキューには非同期という特性があるため、現在の要素数を判定するには要素全体をトラバースする必要があります。したがって、このコレクションがトラバーサル中に変更された場合、不正確な結果が報告されることがあります。また、addAll
、removeAll
、retainAll
、containsAll
、equals
、およびtoArray
の一括オペレーションについて、原子的な実行は保証されていません。たとえば、addAll
オペレーションと並行して動作するイテレータは、追加された要素の一部しか表示しないことがあります。
このクラスとそのイテレータは、Queue
およびIterator
インタフェースのオプションメソッドすべてを実装します。
メモリー整合性効果: ほかの並行処理コレクションと同様、オブジェクトをConcurrentLinkedQueue
に配置する前のスレッド内のアクションは、別のスレッドでのその要素へのアクセスまたはConcurrentLinkedQueue
からの削除に続くアクションよりも前に発生します。
このクラスは、Java Collections Frameworkのメンバーです。
コンストラクタと説明 |
---|
ConcurrentLinkedQueue()
ConcurrentLinkedQueue を作成します。これは最初は空です。 |
ConcurrentLinkedQueue(Collection<? extends E> c)
指定されたコレクションの要素を初期状態で含む(要素はコレクションのイテレータのトラバーサル順に追加)
ConcurrentLinkedQueue を作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
boolean |
add(E e)
キューの末尾に、指定された要素を挿入します。
|
boolean |
addAll(Collection<? extends E> c)
指定されたコレクション内のすべての要素を、指定されたコレクションのイテレータによって返される順序でこのキューの最後に追加します。
|
boolean |
contains(Object o)
指定された要素がキューに含まれている場合に
true を返します。 |
boolean |
isEmpty()
キューに要素がない場合に
true を返します。 |
Iterator<E> |
iterator()
このキュー内の要素を適切な順序で反復処理するイテレータを返します。
|
boolean |
offer(E e)
キューの末尾に、指定された要素を挿入します。
|
E |
peek()
このキューの先頭を取得しますが、削除しません。キューが空の場合は
null を返します。 |
E |
poll()
このキューの先頭を取得および削除します。キューが空の場合は
null を返します。 |
boolean |
remove(Object o)
指定された要素の単一のインスタンスがこのキューに存在する場合は、キューから削除します。
|
int |
size()
キュー内にある要素の数を返します。
|
Spliterator<E> |
spliterator()
このキュー内の要素に対する
Spliterator を返します。 |
Object[] |
toArray()
キュー内のすべての要素を適切な順序で含む配列を返します。
|
<T> T[] |
toArray(T[] a)
キュー内のすべての要素を適切な順序で含む配列を返します。返される配列の実行時の型は、指定された配列の型になります。
|
clear, element, remove
containsAll, removeAll, retainAll, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
clear, containsAll, equals, hashCode, parallelStream, removeAll, removeIf, retainAll, stream
public ConcurrentLinkedQueue()
ConcurrentLinkedQueue
を作成します。これは最初は空です。public ConcurrentLinkedQueue(Collection<? extends E> c)
ConcurrentLinkedQueue
を作成します。c
- 初期状態で含む要素のコレクションNullPointerException
- 指定されたコレクションまたはそのいずれかの要素がnullである場合public boolean add(E e)
IllegalStateException
をスローしないか、false
を返します。add
、インタフェース: Collection<E>
add
、インタフェース: Queue<E>
add
、クラス: AbstractQueue<E>
e
- 追加する要素true
(Collection.add(E)
で指定されているとおり)NullPointerException
- 指定された要素がnullである場合public boolean offer(E e)
false
を返しません。offer
、インタフェース: Queue<E>
e
- 追加する要素true
(Queue.offer(E)
で指定されているとおり)NullPointerException
- 指定された要素がnullである場合public boolean isEmpty()
true
を返します。isEmpty
、インタフェース: Collection<E>
isEmpty
、クラス: AbstractCollection<E>
true
public int size()
Integer.MAX_VALUE
より多くの要素がある場合は、Integer.MAX_VALUE
を返します。
大半のコレクションとは異なり、このメソッドは一定時間のオペレーションではないことに留意してください。これらのキューには非同期という特性があるため、現在の要素数を判定するにはO(n)トラバーサルが必要です。さらに、このメソッドの実行中に要素が追加または削除された場合は、返される結果が不正確になることがあります。そのため、このメソッドは、通常は並行処理アプリケーションではあまり便利ではありません。
size
、インタフェース: Collection<E>
size
、クラス: AbstractCollection<E>
public boolean contains(Object o)
true
を返します。つまり、このキュー内にo.equals(e)
のような1つ以上の要素e
が含まれている場合、true
を返します。contains
、インタフェース: Collection<E>
contains
、クラス: AbstractCollection<E>
o
- このキューに含まれているかどうかを調べるオブジェクトtrue
public boolean remove(Object o)
o.equals(e)
に該当する要素e
が1つ以上含まれている場合は、そのような要素を削除します。指定された要素がこのキューに含まれていた場合、つまり、呼出しの結果としてこのキューが変更された場合にtrue
を返します。remove
、インタフェース: Collection<E>
remove
、クラス: AbstractCollection<E>
o
- キューから削除される要素(その要素が存在する場合)true
public boolean addAll(Collection<? extends E> c)
addAll
しようとすると、IllegalArgumentException
が発生します。addAll
、インタフェース: Collection<E>
addAll
、クラス: AbstractQueue<E>
c
- このキューに挿入される要素true
NullPointerException
- 指定されたコレクションまたはそのいずれかの要素がnullである場合IllegalArgumentException
- コレクションがこのキューである場合AbstractQueue.add(Object)
public Object[] toArray()
返される配列は、それへの参照がこのキューで保持されない場合に、安全になります。(つまり、このメソッドは新しい配列を割り当てる)。このため、呼出し側は、返された配列を自由に変更できます。
このメソッドは、配列ベースのAPIとコレクションベースのAPIの間の橋渡し役として機能します。
toArray
、インタフェース: Collection<E>
toArray
、クラス: AbstractCollection<E>
public <T> T[] toArray(T[] a)
キューが指定された配列に収まり、その配列にさらに余裕がある場合(つまり、配列がキューより多くの要素を持つ場合)、その配列内でキューの終端よりあとの要素はnull
に設定されます。
toArray()
メソッドと同じように、このメソッドは、配列ベースのAPIとコレクションベースのAPIの間の橋渡し役として機能します。さらに、このメソッドでは出力配列の実行時の型を正確に制御できるため、環境によっては割当ての手間を抑えるために使用できます。
x
が、文字列だけからなるキューであることがわかっていると仮定します。次のコードを使うと、新しく割り当てられたString
の配列にキューをダンプできます。
String[] y = x.toArray(new String[0]);
toArray(new Object[0])
は、機能の点でtoArray()
と同一です。toArray
、インタフェース: Collection<E>
toArray
、クラス: AbstractCollection<E>
T
- コレクションを含む配列の実行時の型a
- 配列が十分な大きさを持つ場合は、キューの要素が格納される配列。そうでない場合は、要素を格納するために同じ実行時の型の新しい配列が割り当てられるArrayStoreException
- 指定された配列の実行時の型が、キュー内の各要素の実行時の型のスーパー・タイプでない場合NullPointerException
- 指定された配列がnullである場合public Iterator<E> iterator()
返されるイテレータは弱一貫性を保持します。
iterator
、インタフェース: Iterable<E>
iterator
、インタフェース: Collection<E>
iterator
、クラス: AbstractCollection<E>
public Spliterator<E> spliterator()
Spliterator
を返します。
返されるスプリッテレータは弱一貫性を保持します。
Spliterator
は、Spliterator.CONCURRENT
、Spliterator.ORDERED
およびSpliterator.NONNULL
を報告します。
spliterator
、インタフェース: Iterable<E>
spliterator
、インタフェース: Collection<E>
Spliterator
は、制限付きの並列処理を許可するためにtrySplit
を実装します。Spliterator
バグまたは機能を送信
詳細なAPIリファレンスおよび開発者ドキュメントについては、Java SEのドキュメントを参照してください。そのドキュメントには、概念的な概要、用語の定義、回避方法、有効なコード例などの、開発者を対象にしたより詳細な説明が含まれています。
Copyright© 1993, 2014, Oracle and/or its affiliates. All rights reserved.