java.util.concurrent.SynchronousQueue<E>

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

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

public class SynchronousQueue<E> extends AbstractQueue<E> implements BlockingQueue<E>, Serializable

各挿入オペレーションが別のスレッドによる対応する削除オペレーションを待機する必要がある(およびその逆の) ブロッキング・キューです。同期キューには、内部容量がまったくありません。要素が存在するのは削除しようとするときのみなので、同期キューでpeekを実行することはできません。別のスレッドが削除を試みていないかぎり、どのメソッドを使用しても要素を挿入することはできません。反復するものが存在しないため、反復は実行できません。キューの先頭は、挿入処理スレッドがキューに追加しようとする、最初にキューに入れられた要素です。そのようなキューに入れられたスレッドが存在しない場合は、削除できる要素はなく、poll()はnullを返します。他のCollectionメソッド(containsなど)の目的のために、SynchronousQueueは空のコレクションとして機能します。このキューでは、null要素は許可されません。

同期キューは、CSPおよびAdaで使用されるランデブー・チャネルに似ています。これらはハンドオフ設計に最適です。ハンドオフ設計では、情報、イベント、またはタスクを渡すために、あるスレッドで実行中のオブジェクトを別のスレッドで実行中のオブジェクトと同期させる必要があります。

このクラスでは、待機中のプロデューサおよびコンシューマ・スレッドの順序付けのためのオプションの公平性ポリシーをサポートします。デフォルトでは、この順序付けは保証されていません。ただし、公平性をtrueに設定して構築されたキューでは、スレッドがFIFOの順序でアクセスすることが許可されます。

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

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

導入されたバージョン:

1.5

関連項目:

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

コンストラクタ

コンストラクタ

説明

SynchronousQueue()

不公平アクセス・ポリシーでSynchronousQueueを作成します。

SynchronousQueue(boolean fair)

指定された公平性ポリシーでSynchronousQueueを作成します。
メソッドのサマリー

修飾子と型

メソッド

説明

void

clear()

何も行いません。

boolean

contains(Object o)

常にfalseを返します。

boolean

containsAll(Collection<?> c)

指定されたコレクションが空でないかぎり、falseを返します。

int

drainTo(Collection<? super E> c)

このキューから利用可能なすべての要素を削除し、それらを指定されたコレクションに追加します。

int

drainTo(Collection<? super E> c, int maxElements)

指定された数以内の利用可能な要素をこのキューから削除し、指定されたコレクションに追加します。

boolean

isEmpty()

常にtrueを返します。

Iterator<E>

iterator()

常にhasNextがfalseを返す空のイテレータを返します。

boolean

offer(E e)

別のスレッドが要素を受け取るのを待機している場合、その要素をこのキューに追加します。

boolean

offer(E e, long timeout, TimeUnit unit)

指定された要素をこのキューに挿入します。必要に応じて、指定された待機時間まで別のスレッドが要素を受け取るのを待機します。

E

peek()

常にnullを返します。

E

poll()

別のスレッドが現在要素を利用可能にしている場合は、キューの先頭を取得して削除します。

E

poll(long timeout, TimeUnit unit)

このキューの先頭を取得および削除します。必要に応じて、指定された待機時間まで別のスレッドがその要素を挿入するのを待機します。

void

put(E e)

指定された要素をこのキューに追加します。必要に応じて、別のスレッドが要素を受け取るまで待機します。

int

remainingCapacity()

常にゼロを返します。

boolean

remove(Object o)

常にfalseを返します。

boolean

removeAll(Collection<?> c)

常にfalseを返します。

boolean

retainAll(Collection<?> c)

常にfalseを返します。

int

size()

常にゼロを返します。

Spliterator<E>

spliterator()

trySplitを呼び出すと常にnullが返される空のスプリッテレータを返します。

E

take()

このキューの先頭を取得して削除します。必要に応じて、別のスレッドがその要素を挿入するまで待機します。

Object[]

toArray()

長さがゼロの配列を返します。

<T> T[]

toArray(T[] a)

指定された配列の0(ゼロ)要素をnull (配列の長さがゼロ以外の場合)に設定し、それを返します。

String

toString()

常に"[]"を返します。

クラスjava.util.AbstractQueueで宣言されたメソッド
add, addAll, element, remove

クラスjava.lang.Objectで宣言されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

インタフェースjava.util.Collectionで宣言されたメソッド
addAll, equals, hashCode, parallelStream, removeIf, stream, toArray

インタフェースjava.lang.Iterableで宣言されたメソッド
forEach

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

コンストラクタの詳細
- SynchronousQueue
  
  public SynchronousQueue()
  
  不公平アクセス・ポリシーでSynchronousQueueを作成します。
- SynchronousQueue
  
  public SynchronousQueue(boolean fair)
  
  指定された公平性ポリシーでSynchronousQueueを作成します。
  
  パラメータ:
  
  fair - trueの場合、待機中のスレッドはFIFOの順序でアクセスが決定される。それ以外の場合、順序は指定されない。
メソッドの詳細
- put
  
  public void put(E e) throws InterruptedException
  
  指定された要素をこのキューに追加します。必要に応じて、別のスレッドが要素を受け取るまで待機します。
  
  定義:
  
  put、インタフェースBlockingQueue<E>
  
  パラメータ:
  
  e - 追加する要素
  
  例外:
  
  InterruptedException - 待機中に割込みが発生した場合
  
  NullPointerException - 指定された要素がnullである場合
- offer
  
  public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException
  
  指定された要素をこのキューに挿入します。必要に応じて、指定された待機時間まで別のスレッドが要素を受け取るのを待機します。
  
  定義:
  
  offer、インタフェースBlockingQueue<E>
  
  パラメータ:
  
  e - 追加する要素
  
  timeout - 処理を中止するまでの待機時間。単位はunit
  
  unit - timeoutパラメータの解釈方法を決定するTimeUnit
  
  戻り値:
  
  成功した場合はtrue。コンシューマが出現する前に指定された待機時間が経過した場合はfalse
  
  例外:
  
  InterruptedException - 待機中に割込みが発生した場合
  
  NullPointerException - 指定された要素がnullである場合
- offer
  
  public boolean offer(E e)
  
  別のスレッドが要素を受け取るのを待機している場合、その要素をこのキューに追加します。
  
  定義:
  
  offer、インタフェースBlockingQueue<E>
  
  定義:
  
  offer、インタフェースQueue<E>
  
  パラメータ:
  
  e - 追加する要素
  
  戻り値:
  
  このキューに要素が追加された場合はtrue、それ以外の場合はfalse
  
  例外:
  
  NullPointerException - 指定された要素がnullである場合
- take
  
  public E take() throws InterruptedException
  
  このキューの先頭を取得して削除します。必要に応じて、別のスレッドがその要素を挿入するまで待機します。
  
  定義:
  
  take、インタフェースBlockingQueue<E>
  
  戻り値:
  
  キューの先頭
  
  例外:
  
  InterruptedException - 待機中に割込みが発生した場合
- poll
  
  public E poll(long timeout, TimeUnit unit) throws InterruptedException
  
  このキューの先頭を取得および削除します。必要に応じて、指定された待機時間まで別のスレッドがその要素を挿入するのを待機します。
  
  定義:
  
  poll、インタフェースBlockingQueue<E>
  
  パラメータ:
  
  timeout - 処理を中止するまでの待機時間。単位はunit
  
  unit - timeoutパラメータの解釈方法を決定するTimeUnit
  
  戻り値:
  
  このキューの先頭。要素が存在する前に指定された待機時間が経過した場合はnull
  
  例外:
  
  InterruptedException - 待機中に割込みが発生した場合
- poll
  
  public E poll()
  
  別のスレッドが現在要素を利用可能にしている場合は、キューの先頭を取得して削除します。
  
  定義:
  
  poll、インタフェースQueue<E>
  
  戻り値:
  
  このキューの先頭。要素が使用できない場合はnull
- isEmpty
  
  public boolean isEmpty()
  
  常にtrueを返します。 SynchronousQueueには内部容量がありません。
  
  定義:
  
  isEmpty、インタフェースCollection<E>
  
  オーバーライド:
  
  isEmpty、クラスAbstractCollection<E>
  
  戻り値:
  
  true
- size
  
  public int size()
  
  常にゼロを返します。 SynchronousQueueには内部容量がありません。
  
  定義:
  
  size、インタフェースCollection<E>
  
  戻り値:
  
  zero
- remainingCapacity
  
  public int remainingCapacity()
  
  常にゼロを返します。 SynchronousQueueには内部容量がありません。
  
  定義:
  
  remainingCapacity、インタフェースBlockingQueue<E>
  
  戻り値:
  
  zero
- clear
  
  public void clear()
  
  何も行いません。 SynchronousQueueには内部容量がありません。
  
  定義:
  
  clear、インタフェースCollection<E>
  
  オーバーライド:
  
  clear、クラスAbstractQueue<E>
- contains
  
  public boolean contains(Object o)
  
  常にfalseを返します。 SynchronousQueueには内部容量がありません。
  
  定義:
  
  contains、インタフェースBlockingQueue<E>
  
  定義:
  
  contains、インタフェースCollection<E>
  
  オーバーライド:
  
  contains、クラスAbstractCollection<E>
  
  パラメータ:
  
  o - 要素
  
  戻り値:
  
  false
- remove
  
  public boolean remove(Object o)
  
  常にfalseを返します。 SynchronousQueueには内部容量がありません。
  
  定義:
  
  remove、インタフェースBlockingQueue<E>
  
  定義:
  
  remove、インタフェースCollection<E>
  
  オーバーライド:
  
  remove、クラスAbstractCollection<E>
  
  パラメータ:
  
  o - 削除する要素
  
  戻り値:
  
  false
- containsAll
  
  public boolean containsAll(Collection<?> c)
  
  指定されたコレクションが空でないかぎり、falseを返します。 SynchronousQueueには内部容量がありません。
  定義:
  
  containsAll、インタフェースCollection<E>
  
  オーバーライド:
  
  containsAll、クラスAbstractCollection<E>
  
  パラメータ:
  
  c - コレクション
  
  戻り値:
  
  指定されたコレクションが空でないかぎりfalse
  
  関連項目:
  
  AbstractCollection.contains(Object)
- removeAll
  
  public boolean removeAll(Collection<?> c)
  
  常にfalseを返します。 SynchronousQueueには内部容量がありません。
  定義:
  
  removeAll、インタフェースCollection<E>
  
  オーバーライド:
  
  removeAll、クラスAbstractCollection<E>
  
  パラメータ:
  
  c - コレクション
  
  戻り値:
  
  false
  
  関連項目:
  
  AbstractCollection.remove(Object)
  
  AbstractCollection.contains(Object)
- retainAll
  
  public boolean retainAll(Collection<?> c)
  
  常にfalseを返します。 SynchronousQueueには内部容量がありません。
  定義:
  
  retainAll、インタフェースCollection<E>
  
  オーバーライド:
  
  retainAll、クラスAbstractCollection<E>
  
  パラメータ:
  
  c - コレクション
  
  戻り値:
  
  false
  
  関連項目:
  
  AbstractCollection.remove(Object)
  
  AbstractCollection.contains(Object)
- peek
  
  public E peek()
  
  常にnullを返します。アクティブに待機されないかぎり、SynchronousQueueは要素を返しません。
  
  定義:
  
  peek、インタフェースQueue<E>
  
  戻り値:
  
  null
- iterator
  
  public Iterator<E> iterator()
  
  常にhasNextがfalseを返す空のイテレータを返します。
  
  定義:
  
  iterator、インタフェースCollection<E>
  
  定義:
  
  iterator、インタフェースIterable<E>
  
  定義:
  
  iterator、クラスAbstractCollection<E>
  
  戻り値:
  
  空のイテレータ
- spliterator
  
  public Spliterator<E> spliterator()
  
  trySplitを呼び出すと常にnullが返される空のスプリッテレータを返します。
  
  定義:
  
  spliterator、インタフェースCollection<E>
  
  定義:
  
  spliterator、インタフェースIterable<E>
  
  戻り値:
  
  空のスプリッテレータ
  
  導入されたバージョン:
  
  1.8
- toArray
  
  public Object[] toArray()
  
  長さがゼロの配列を返します。
  
  定義:
  
  toArray、インタフェースCollection<E>
  
  オーバーライド:
  
  toArray、クラスAbstractCollection<E>
  
  戻り値:
  
  長さがゼロの配列
- toArray
  
  public <T> T[] toArray(T[] a)
  
  指定された配列の0(ゼロ)要素をnull (配列の長さがゼロ以外の場合)に設定し、それを返します。
  
  定義:
  
  toArray、インタフェースCollection<E>
  
  オーバーライド:
  
  toArray、クラスAbstractCollection<E>
  
  型パラメータ:
  
  T - コレクションを格納する配列のコンポーネント型
  
  パラメータ:
  
  a - 配列
  
  戻り値:
  
  指定された配列
  
  例外:
  
  NullPointerException - 指定された配列がnullである場合
- toString
  
  public String toString()
  
  常に"[]"を返します。
  
  オーバーライド:
  
  toString、クラスAbstractCollection<E>
  
  戻り値:
  
  "[]"
- drainTo
  
  public int drainTo(Collection<? super E> c)
  
  インタフェースからコピーされた説明: BlockingQueue
  
  このキューから利用可能なすべての要素を削除し、それらを指定されたコレクションに追加します。このオペレーションは、このキューを繰返しポーリングする場合よりも効率的な場合があります。コレクションcに要素を追加しようとしたときに障害が発生すると、関連する例外のスロー時に、要素がこのキューとコレクションのいずれにも存在しない場合と、一方または両方に存在する場合があります。キューをそれ自体に排出しようとすると、IllegalArgumentExceptionがスローされます。また、オペレーションの進行中に指定されたコレクションが変更された場合の、このオペレーションの動作は定義されていません。
  
  定義:
  
  drainTo、インタフェースBlockingQueue<E>
  
  パラメータ:
  
  c - 要素の転送先のコレクション
  
  戻り値:
  
  転送された要素の数
  
  例外:
  
  UnsupportedOperationException - 指定されたコレクションで追加の要素がサポートされていない場合
  
  ClassCastException - このキューの要素のクラスが原因で、その要素を指定されたコレクションに追加できない場合
  
  NullPointerException - 指定されたコレクションがnullである場合
  
  IllegalArgumentException - 指定されたコレクションがこのキューである場合、またはこのキューの要素のあるプロパティが原因で指定されたコレクションに追加できない場合
- drainTo
  
  public int drainTo(Collection<? super E> c, int maxElements)
  
  インタフェースからコピーされた説明: BlockingQueue
  
  指定された数以内の利用可能な要素をこのキューから削除し、指定されたコレクションに追加します。コレクションcに要素を追加しようとしたときに障害が発生すると、関連する例外のスロー時に、要素がこのキューとコレクションのいずれにも存在しない場合と、一方または両方に存在する場合があります。キューをそれ自体に排出しようとすると、IllegalArgumentExceptionがスローされます。また、オペレーションの進行中に指定されたコレクションが変更された場合の、このオペレーションの動作は定義されていません。
  
  定義:
  
  drainTo、インタフェースBlockingQueue<E>
  
  パラメータ:
  
  c - 要素の転送先のコレクション
  
  maxElements - 転送する要素の最大数
  
  戻り値:
  
  転送された要素の数
  
  例外:
  
  UnsupportedOperationException - 指定されたコレクションで追加の要素がサポートされていない場合
  
  ClassCastException - このキューの要素のクラスが原因で、その要素を指定されたコレクションに追加できない場合
  
  NullPointerException - 指定されたコレクションがnullである場合
  
  IllegalArgumentException - 指定されたコレクションがこのキューである場合、またはこのキューの要素のあるプロパティが原因で指定されたコレクションに追加できない場合

クラスSynchronousQueue<E>

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

メソッドのサマリー

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

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

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

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

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

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

コンストラクタの詳細

SynchronousQueue

SynchronousQueue

メソッドの詳細

put

offer

offer

take

poll

poll

isEmpty

size

remainingCapacity

clear

contains

remove

containsAll

removeAll

retainAll

peek

iterator

spliterator

toArray

toArray

toString

drainTo

drainTo