java.util.concurrent.LinkedTransferQueue<E>

型パラメータ:: E - このキューに保持されている要素の型

すべての実装されたインタフェース:: Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, TransferQueue<E>, Queue<E>

public class LinkedTransferQueue<E>
extends AbstractQueue<E>
implements TransferQueue<E>, Serializable

リンク・ノードに基づく、制限なしのTransferQueueです。このキューは、指定された任意のプロデューサに関して、FIFO (先入れ先出し)で要素を順序付けします。キューの先頭は、特定のプロデューサに関して、もっとも長い時間キューに入っていた要素です。キューの末尾は、特定のプロデューサに関して、もっとも短い時間キューに入っていた要素です。

大半のコレクションとは異なり、sizeメソッドは一定時間のオペレーションではないことに留意してください。これらのキューには非同期という特性があるため、現在の要素数を判定するには要素全体をトラバースする必要があります。したがって、このコレクションがトラバーサル中に変更された場合、不正確な結果が報告されることがあります。

AbstractQueue.addAll(java.util.Collection<? extends E>)、removeIf(java.util.function.Predicate<? super E>)、forEach(java.util.function.Consumer<? super E>)などの複数の要素を追加、削除、または検査するバルク操作は、アトミックに実行されることは保証されていません。たとえば、 addAll操作と並行してforEachを走査すると、追加された要素の一部しか観察されない可能性があります。

このクラスとそのイテレータは、CollectionおよびIteratorインタフェースのオプション・メソッドすべてを実装します。

メモリー整合性効果: ほかの並行処理コレクションと同様、オブジェクトをLinkedTransferQueueに配置する前のスレッド内のアクションは、別のスレッドでのその要素へのアクセスまたはLinkedTransferQueueからの削除に続くアクションよりも前に発生します。

このクラスは、Java Collections Frameworkのメンバーです。

導入されたバージョン:: 1.7
関連項目:: 直列化された形式

コンストラクタのサマリー

コンストラクタ
コンストラクタ	説明
`LinkedTransferQueue()`	初期状態で空の`LinkedTransferQueue`を作成します。
`LinkedTransferQueue(Collection<? extends E> c)`	指定されたコレクションの要素を初期状態で含む(要素はコレクションのイテレータのトラバーサル順に追加) `LinkedTransferQueue`を作成します。

メソッドのサマリー

修飾子と型	メソッド	説明
`boolean`	`add(E e)`	キューの末尾に、指定された要素を挿入します。
`boolean`	`contains(Object o)`	指定された要素がキューに含まれている場合に`true`を返します。
`int`	`drainTo(Collection<? super E> c)`	このキューから利用可能なすべての要素を削除し、それらを指定されたコレクションに追加します。
`int`	`drainTo(Collection<? super E> c, int maxElements)`	指定された数以内の利用可能な要素をこのキューから削除し、指定されたコレクションに追加します。
`void`	`forEach(Consumer<? super E> action)`	`Iterable`の各要素に対して指定されたアクションを、すべての要素が処理されるか、アクションが例外をスローするまで実行します。
`boolean`	`isEmpty()`	キューに要素がない場合に`true`を返します。
`Iterator<E>`	`iterator()`	このキュー内の要素を適切な順序で反復処理するイテレータを返します。
`boolean`	`offer(E e)`	キューの末尾に、指定された要素を挿入します。
`boolean`	`offer(E e, long timeout, TimeUnit unit)`	キューの末尾に、指定された要素を挿入します。
`void`	`put(E e)`	キューの末尾に、指定された要素を挿入します。
`int`	`remainingCapacity()`	`LinkedTransferQueue`は容量制約を受けないため、常に`Integer.MAX_VALUE`を返します。
`boolean`	`remove(Object o)`	指定された要素の単一のインスタンスがこのキューに存在する場合は、キューから削除します。
`boolean`	`removeAll(Collection<?> c)`	指定されたコレクションにも格納されているこのコレクションのすべての要素を削除します(オプションの操作)。
`boolean`	`removeIf(Predicate<? super E> filter)`	指定された述語を満たすこのコレクションの要素をすべて削除します。
`boolean`	`retainAll(Collection<?> c)`	このコレクションにおいて、指定されたコレクションに格納されている要素だけを保持します(オプションの操作)。
`int`	`size()`	キュー内にある要素の数を返します。
`Spliterator<E>`	`spliterator()`	このキュー内の要素に対する`Spliterator`を返します。
`Object[]`	`toArray()`	キュー内のすべての要素を適切な順序で含む配列を返します。
`<T> T[]`	`toArray(T[] a)`	キュー内のすべての要素を適切な順序で含む配列を返します。返される配列の実行時の型は、指定された配列の型になります。
`void`	`transfer(E e)`	待機する必要があれば待機し、要素をコンシューマに転送します。
`boolean`	`tryTransfer(E e)`	可能な場合、待機中のコンシューマに要素をただちに転送します。
`boolean`	`tryTransfer(E e, long timeout, TimeUnit unit)`	タイム・アウトが経過する前に要素をコンシューマに転送できる場合には、そうします。

クラス java.util.AbstractQueueで宣言されたメソッド

addAll, clear, element, remove

クラス java.util.AbstractCollectionで宣言されたメソッド

containsAll, toString

クラス java.lang.Objectで宣言されたメソッド

clone、equals、finalize、getClass、hashCode、notify、notifyAll、wait、wait、wait

インタフェース java.util.concurrent.BlockingQueueで宣言されたメソッド

poll, take

インタフェース java.util.Collectionで宣言されたメソッド

addAll, clear, containsAll, equals, hashCode, parallelStream, stream, toArray

インタフェース java.util.Queueで宣言されたメソッド

element, peek, poll, remove

インタフェース java.util.concurrent.TransferQueueで宣言されたメソッド

getWaitingConsumerCount, hasWaitingConsumer

コンストラクタの詳細
- LinkedTransferQueue
  
  public LinkedTransferQueue()
  
  初期状態で空のLinkedTransferQueueを作成します。
- LinkedTransferQueue
  
  public LinkedTransferQueue(Collection<? extends E> c)
  
  指定されたコレクションの要素を初期状態で含む(要素はコレクションのイテレータのトラバーサル順に追加) LinkedTransferQueueを作成します。
  
  パラメータ:
  
  c - 初期状態で含む要素のコレクション
  
  例外:
  
  NullPointerException - 指定されたコレクションまたはそのいずれかの要素がnullである場合
メソッドの詳細
- toArray
  
  public Object[] toArray()
  
  キュー内のすべての要素を適切な順序で含む配列を返します。
  返される配列は、それへの参照がこのキューで保持されない場合に、安全になります。 (つまり、このメソッドは新しい配列を割り当てます。) このため、呼出し側は、返された配列を自由に変更できます。
  このメソッドは、配列ベースのAPIとコレクションベースのAPIの間の橋渡し役として機能します。
  
  定義:
  
  toArray、インタフェース: Collection<E>
  
  オーバーライド:
  
  toArray、クラス: AbstractCollection<E>
  
  戻り値:
  
  このキューのすべての要素が含まれている配列
- toArray
  
  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である場合
- spliterator
  
  public Spliterator<E> spliterator()
  
  このキュー内の要素に対するSpliteratorを返します。
  返されるスプリッテレータは弱一貫性を保持します。
  Spliteratorは、Spliterator.CONCURRENT、Spliterator.ORDEREDおよびSpliterator.NONNULLを報告します。
  
  定義:
  
  spliterator、インタフェース: Collection<E>
  
  定義:
  
  spliterator、インタフェース: Iterable<E>
  
  実装上の注意:
  
  Spliteratorは、制限付きの並列処理を許可するためにtrySplitを実装します。
  
  戻り値:
  
  このキュー内の要素に対するSpliterator
  
  導入されたバージョン:
  
  1.8
- put
  
  public void put(E e)
  
  キューの末尾に、指定された要素を挿入します。キューがアンバウンド形式であるため、このメソッドはブロックを実行しません。
  
  定義:
  
  put、インタフェース: BlockingQueue<E>
  
  パラメータ:
  
  e - 追加する要素
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
- offer
  
  public boolean offer(E e, long timeout, TimeUnit unit)
  
  キューの末尾に、指定された要素を挿入します。キューがアンバウンド形式であるため、このメソッドはブロックを実行しないか、falseを返しません。
  
  定義:
  
  offer、インタフェース: BlockingQueue<E>
  
  パラメータ:
  
  e - 追加する要素
  
  timeout - 処理を中止するまでの待機時間。単位はunit
  
  unit - timeoutパラメータの解釈方法を決定するTimeUnit
  
  戻り値:
  
  true (BlockingQueue.offerで指定されているとおり)
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
- offer
  
  public boolean offer(E e)
  
  キューの末尾に、指定された要素を挿入します。キューがアンバウンド形式であるため、このメソッドはfalseを返しません。
  
  定義:
  
  offer、インタフェース: BlockingQueue<E>
  
  定義:
  
  offer、インタフェース: Queue<E>
  
  パラメータ:
  
  e - 追加する要素
  
  戻り値:
  
  true (Queue.offer(E)で指定されているとおり)
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
- add
  
  public boolean add(E e)
  
  キューの末尾に、指定された要素を挿入します。キューがアンバウンド形式であるため、このメソッドはIllegalStateExceptionをスローしないか、falseを返します。
  
  定義:
  
  add 、インタフェース: BlockingQueue<E>
  
  定義:
  
  add、インタフェース: Collection<E>
  
  定義:
  
  add、インタフェース: Queue<E>
  
  オーバーライド:
  
  add、クラス: AbstractQueue<E>
  
  パラメータ:
  
  e - 追加する要素
  
  戻り値:
  
  true (Collection.add(E)で指定されているとおり)
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
- tryTransfer
  
  public boolean tryTransfer(E e)
  
  可能な場合、待機中のコンシューマに要素をただちに転送します。
  より正確には、(BlockingQueue.take()または時間指定のpollで)要素を受け取ることを待機しているコンシューマがすでに存在する場合は指定された要素をただちに転送し、それ以外の場合は要素をエンキューせずにfalseを返します。
  
  定義:
  
  tryTransfer、インタフェース: TransferQueue<E>
  
  パラメータ:
  
  e - 転送する要素
  
  戻り値:
  
  true - 要素が転送された場合。それ以外の場合はfalse
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
- 転送
  
  public void transfer(E e) throws InterruptedException
  
  待機する必要があれば待機し、要素をコンシューマに転送します。
  より正確には、指定された要素を、すでに受信待ちのコンシューマが存在する場合は直ちに転送し、そうでない場合は、指定された要素をこのキューの末尾に挿入し、要素がコンシューマによって受信されるまで待機します。
  
  定義:
  
  transfer、インタフェース: TransferQueue<E>
  
  パラメータ:
  
  e - 転送する要素
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
  
  InterruptedException - 待機中に割り込まれた場合。この場合、要素はエンキューされたままになりません
- tryTransfer
  
  public boolean tryTransfer(E e, long timeout, TimeUnit unit) throws InterruptedException
  
  タイム・アウトが経過する前に要素をコンシューマに転送できる場合には、そうします。
  より正確には、指定された要素がすでに受信待ちのコンシューマが存在する場合は直ちにそれを転送し、そうでない場合は指定された要素をこのキューの末尾に挿入し、コンシューマが要素を受信するまで待ち、指定された待機時間が経過するとfalseを返します。要素を転送することができます。
  
  定義:
  
  tryTransfer、インタフェース: TransferQueue<E>
  
  パラメータ:
  
  e - 転送する要素
  
  timeout - 処理を中止するまでの待機時間。単位はunit
  
  unit - timeoutパラメータの解釈方法を決定するTimeUnit
  
  戻り値:
  
  成功した場合はtrue、完了前に指定された待機時間が経過した場合はfalseで、この場合、要素はエンキューされたままになりません
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
  
  InterruptedException - 待機中に割り込まれた場合。この場合、要素はエンキューされたままになりません
- drainTo
  
  public int drainTo(Collection<? super E> c)
  
  インタフェースからコピーされた説明: BlockingQueue
  
  このキューから利用可能なすべての要素を削除し、それらを指定されたコレクションに追加します。このオペレーションは、このキューを繰返しポーリングする場合よりも効率的な場合があります。コレクションcに要素を追加しようとしたときに障害が発生すると、関連する例外のスロー時に、要素がこのキューとコレクションのいずれにも存在しない場合と、一方または両方に存在する場合があります。キューをそれ自体に排出しようとすると、IllegalArgumentExceptionがスローされます。また、オペレーションの進行中に指定されたコレクションが変更された場合の、このオペレーションの動作は定義されていません。
  
  定義:
  
  drainTo、インタフェース: BlockingQueue<E>
  
  パラメータ:
  
  c - 要素の転送先のコレクション
  
  戻り値:
  
  転送された要素の数
  
  例外:
  
  NullPointerException - 指定されたコレクションがnullである場合
  
  IllegalArgumentException - 指定されたコレクションがこのキューである場合、またはこのキューの要素のあるプロパティが原因で指定されたコレクションに追加できない場合
- drainTo
  
  public int drainTo(Collection<? super E> c, int maxElements)
  
  インタフェースからコピーされた説明: BlockingQueue
  
  指定された数以内の利用可能な要素をこのキューから削除し、指定されたコレクションに追加します。コレクションcに要素を追加しようとしたときに障害が発生すると、関連する例外のスロー時に、要素がこのキューとコレクションのいずれにも存在しない場合と、一方または両方に存在する場合があります。キューをそれ自体に排出しようとすると、IllegalArgumentExceptionがスローされます。また、オペレーションの進行中に指定されたコレクションが変更された場合の、このオペレーションの動作は定義されていません。
  
  定義:
  
  drainTo、インタフェース: BlockingQueue<E>
  
  パラメータ:
  
  c - 要素の転送先のコレクション
  
  maxElements - 転送する要素の最大数
  
  戻り値:
  
  転送された要素の数
  
  例外:
  
  NullPointerException - 指定されたコレクションがnullである場合
  
  IllegalArgumentException - 指定されたコレクションがこのキューである場合、またはこのキューの要素のあるプロパティが原因で指定されたコレクションに追加できない場合
- iterator
  
  public Iterator<E> iterator()
  
  このキュー内の要素を適切な順序で反復処理するイテレータを返します。要素は最初(先頭)から最後(末尾)の順に返されます。
  返されるイテレータは弱一貫性を保持します。
  
  定義:
  
  iterator、インタフェース: Collection<E>
  
  定義:
  
  iterator、インタフェース: Iterable<E>
  
  定義:
  
  iterator、クラス: AbstractCollection<E>
  
  戻り値:
  
  キュー内の要素を適切な順序で繰返し処理するイテレータ
- isEmpty
  
  public boolean isEmpty()
  
  キューに要素がない場合にtrueを返します。
  
  定義:
  
  isEmpty、インタフェース: Collection<E>
  
  オーバーライド:
  
  isEmpty、クラス: AbstractCollection<E>
  
  戻り値:
  
  キューに要素がない場合はtrue
- size
  
  public int size()
  
  キュー内にある要素の数を返します。このキューにInteger.MAX_VALUEより多くの要素がある場合は、Integer.MAX_VALUEを返します。
  大半のコレクションとは異なり、このメソッドは一定時間のオペレーションではないことに留意してください。これらのキューには非同期という特性があるため、現在の要素数を判定するにはO(n)トラバーサルが必要です。
  
  定義:
  
  size、インタフェース: Collection<E>
  
  戻り値:
  
  キューの要素数
- remove
  
  public boolean remove(Object o)
  
  指定された要素の単一のインスタンスがこのキューに存在する場合は、キューから削除します。つまり、キュー内に、o.equals(e)に該当する要素eが1つ以上含まれている場合は、そのような要素を削除します。指定された要素がこのキューに含まれていた場合、つまり、呼出しの結果としてこのキューが変更された場合にtrueを返します。
  
  定義:
  
  remove、インタフェース: BlockingQueue<E>
  
  定義:
  
  remove、インタフェース: Collection<E>
  
  オーバーライド:
  
  remove、クラス: AbstractCollection<E>
  
  パラメータ:
  
  o - キューから削除される要素(その要素が存在する場合)
  
  戻り値:
  
  この呼出しの結果、このキューが変更された場合はtrue
- contains
  
  public boolean contains(Object o)
  
  指定された要素がキューに含まれている場合にtrueを返します。つまり、このキュー内にo.equals(e)のような1つ以上の要素eが含まれている場合、trueを返します。
  
  定義:
  
  contains、インタフェース: BlockingQueue<E>
  
  定義:
  
  contains、インタフェース: Collection<E>
  
  オーバーライド:
  
  contains、クラス: AbstractCollection<E>
  
  パラメータ:
  
  o - このキューに含まれているかどうかを調べるオブジェクト
  
  戻り値:
  
  指定された要素がこのキューに含まれている場合はtrue
- remainingCapacity
  
  public int remainingCapacity()
  
  LinkedTransferQueueは容量制約を受けないため、常にInteger.MAX_VALUEを返します。
  
  定義:
  
  remainingCapacity、インタフェース: BlockingQueue<E>
  
  戻り値:
  
  Integer.MAX_VALUE (BlockingQueue.remainingCapacity()で指定されているとおり)
- removeIf
  
  public boolean removeIf(Predicate<? super E> filter)
  
  次のインタフェースからコピーされた説明: Collection
  
  指定された述語を満たすこのコレクションの要素をすべて削除します。反復中に、または述語によってスローされたエラーまたは実行時例外は、呼出し側に中継されます。
  
  定義:
  
  removeIf、インタフェース: Collection<E>
  
  パラメータ:
  
  filter - 削除される要素に対してtrueを返す述語
  
  戻り値:
  
  要素が削除された場合はtrue
  
  例外:
  
  NullPointerException - 指定されたフィルタがnullである場合
- removeAll
  
  public boolean removeAll(Collection<?> c)
  
  次のクラスからコピーされた説明: AbstractCollection
  
  指定されたコレクションにも格納されているこのコレクションのすべての要素を削除します(オプションの操作)。この呼出しの結果、このコレクションには指定されたコレクションと共通の要素はなくなります。
  
  定義:
  
  removeAll、インタフェース: Collection<E>
  
  オーバーライド:
  
  removeAll、クラス: AbstractCollection<E>
  
  パラメータ:
  
  c - このコレクションから削除される要素を含むコレクション
  
  戻り値:
  
  呼出しの結果としてこのコレクションが変更された場合はtrue
  
  例外:
  
  NullPointerException - このコレクションに1つ以上のnull要素が含まれており、指定されたコレクションがnull要素をサポートしない場合(オプション)、または指定されたコレクションがnullの場合
  
  関連項目:
  
  AbstractCollection.remove(Object), AbstractCollection.contains(Object)
- retainAll
  
  public boolean retainAll(Collection<?> c)
  
  次のクラスからコピーされた説明: AbstractCollection
  
  このコレクションにおいて、指定されたコレクションに格納されている要素だけを保持します(オプションの操作)。つまり、指定されたコレクションに格納されていないすべての要素をこのコレクションから削除します。
  
  定義:
  
  retainAll、インタフェース: Collection<E>
  
  オーバーライド:
  
  retainAll、クラス: AbstractCollection<E>
  
  パラメータ:
  
  c - このコレクションで保持される要素を含むコレクション
  
  戻り値:
  
  呼出しの結果としてこのコレクションが変更された場合はtrue
  
  例外:
  
  NullPointerException - このコレクションに1つ以上のnull要素が含まれており、指定されたコレクションがnull要素を許可しない場合(オプション)、または指定されたコレクションがnullの場合
  
  関連項目:
  
  AbstractCollection.remove(Object), AbstractCollection.contains(Object)
- forEach
  
  public void forEach(Consumer<? super E> action)
  
  インタフェースからコピーされた説明: Iterable
  
  Iterableの各要素に対して指定されたアクションを、すべての要素が処理されるか、アクションが例外をスローするまで実行します。反復の順序でアクションが実行されます(その順序が指定されている場合)。アクションによってスローされた例外は、呼出し側に中継されます。
  オーバーライドするクラスが並行変更ポリシーを指定していない限り、アクションが要素の基本ソースを変更する副作用を実行する場合、このメソッドの動作は指定されていません。
  
  定義:
  
  forEach、インタフェース: Iterable<E>
  
  パラメータ:
  
  action - 各要素に対して実行されるアクション
  
  例外:
  
  NullPointerException - 指定されたアクションがnullである場合

クラスLinkedTransferQueue<E>