モジュール java.base
パッケージ java.util.concurrent

クラスConcurrentLinkedQueue<E>

  • 型パラメータ:
    E - このキューに保持されている要素の型
    すべての実装されたインタフェース:
    Serializable, Iterable<E>, Collection<E>, Queue<E>
    public class ConcurrentLinkedQueue<E>
extends AbstractQueue<E>
implements Queue<E>, Serializable
    リンク・ノードに基づく、制限なしのスレッド・セーフなキューです。 このキューはFIFO (先入れ先出し)で要素を順序付けします。 このキューの先頭は、キューに入っていた時間がもっとも長い要素です。 このキューの末尾は、キューに入っていた時間がもっとも短い要素です。 新しい要素はキューの末尾に挿入され、キュー取得オペレーションにより、キューの先頭の要素が取得されます。 共通のコレクションへのアクセスを多数のスレッドが共有する場合、ConcurrentLinkedQueueは選択肢として適切です。 大半のコレクション実装と同様、このクラスはnull要素の使用を許容しません。

    この実装では、効率のよい非ブロックのアルゴリズムが使用されます。このアルゴリズムは次の資料で記述されているものに基づきます: Simple, Fast, and Practical Non-Blocking and Blocking Concurrent Queue AlgorithmsMaged M. Michael、Michael L. Scott

    イテレータは弱一貫性を持ち、ある時点での、またはイテレータの作成以降のキューの状態を反映する要素を返します。 これらはConcurrentModificationExceptionをスローせず、ほかのオペレーションとの並行処理が可能です。 イテレータの作成以降にキューに含まれた要素が1回だけ返されます。

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

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

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

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

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

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

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

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

    • メソッドのサマリー

      すべてのメソッド インスタンス・メソッド 具象メソッド 
      修飾子と型 メソッド 説明
      boolean add​(E e)
      キューの末尾に、指定された要素を挿入します。
      boolean addAll​(Collection<? extends E> c)
      指定されたコレクション内のすべての要素を、指定されたコレクションのイテレータによって返される順序でこのキューの最後に追加します。
      boolean contains​(Object o)
      指定された要素がキューに含まれている場合にtrueを返します。
      void forEach​(Consumer<? super E> action)
      Iterableの各要素に対して指定されたアクションを、すべての要素が処理されるか、アクションが例外をスローするまで実行します。
      boolean isEmpty()
      キューに要素がない場合にtrueを返します。
      Iterator<E> iterator()
      このキュー内の要素を適切な順序で反復処理するイテレータを返します。
      boolean offer​(E e)
      キューの末尾に、指定された要素を挿入します。
      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)
      キュー内のすべての要素を適切な順序で含む配列を返します。返される配列の実行時の型は、指定された配列の型になります。

    • コンストラクタの詳細

      • ConcurrentLinkedQueue

        public ConcurrentLinkedQueue()
        ConcurrentLinkedQueueを作成します。これは最初は空です。

      • ConcurrentLinkedQueue

        public ConcurrentLinkedQueue​(Collection<? extends E> c)
        指定されたコレクションの要素を初期状態で含む(要素はコレクションのイテレータのトラバーサル順に追加) ConcurrentLinkedQueueを作成します。
        パラメータ:
        c - 初期状態で含む要素のコレクション
        例外:
        NullPointerException - 指定されたコレクションまたはそのいずれかの要素がnullである場合

    • メソッドの詳細

      • add

        public boolean add​(E e)
        キューの末尾に、指定された要素を挿入します。 キューがアンバウンド形式であるため、このメソッドはIllegalStateExceptionをスローしないか、falseを返します。
        定義:
        add、インタフェース: Collection<E>
        定義:
        add、インタフェース: Queue<E>
        オーバーライド:
        add、クラス: AbstractQueue<E>
        パラメータ:
        e - 追加する要素
        戻り値:
        true (Collection.add(E)で指定されているとおり)
        例外:
        NullPointerException - 指定された要素がnullである場合

      • offer

        public boolean offer​(E e)
        キューの末尾に、指定された要素を挿入します。 キューがアンバウンド形式であるため、このメソッドはfalseを返しません。
        定義:
        offer、インタフェース: Queue<E>
        パラメータ:
        e - 追加する要素
        戻り値:
        true (Queue.offer(E)で指定されているとおり)
        例外:
        NullPointerException - 指定された要素がnullである場合

      • 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>
        戻り値:
        キューの要素数

      • contains

        public boolean contains​(Object o)
        指定された要素がキューに含まれている場合にtrueを返します。 つまり、このキュー内にo.equals(e)のような1つ以上の要素eが含まれている場合、trueを返します。
        定義:
        contains、インタフェース: Collection<E>
        オーバーライド:
        contains、クラス: AbstractCollection<E>
        パラメータ:
        o - このキューに含まれているかどうかを調べるオブジェクト
        戻り値:
        指定された要素がこのキューに含まれている場合はtrue

      • remove

        public boolean remove​(Object o)
        指定された要素の単一のインスタンスがこのキューに存在する場合は、キューから削除します。 つまり、キュー内に、o.equals(e)に該当する要素eが1つ以上含まれている場合は、そのような要素を削除します。 指定された要素がこのキューに含まれていた場合、つまり、呼出しの結果としてこのキューが変更された場合にtrueを返します。
        定義:
        remove、インタフェース: Collection<E>
        オーバーライド:
        remove、クラス: AbstractCollection<E>
        パラメータ:
        o - キューから削除される要素(その要素が存在する場合)
        戻り値:
        この呼出しの結果、このキューが変更された場合はtrue

      • addAll

        public boolean addAll​(Collection<? extends E> c)
        指定されたコレクション内のすべての要素を、指定されたコレクションのイテレータによって返される順序でこのキューの最後に追加します。 キューをそれ自体に対してaddAllしようとすると、IllegalArgumentExceptionが発生します。
        定義:
        addAll、インタフェース: Collection<E>
        オーバーライド:
        addAll、クラス: AbstractQueue<E>
        パラメータ:
        c - このキューに挿入される要素
        戻り値:
        この呼出しの結果、このキューが変更された場合はtrue
        例外:
        NullPointerException - 指定されたコレクションまたはそのいずれかの要素がnullである場合
        IllegalArgumentException - コレクションがこのキューである場合
        関連項目:
        AbstractQueue.add(Object)

      • 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である場合

      • iterator

        public Iterator<E> iterator()
        このキュー内の要素を適切な順序で反復処理するイテレータを返します。 要素は最初(先頭)から最後(末尾)の順に返されます。

        返されるイテレータは弱一貫性を保持します。

        定義:
        iterator、インタフェース: Collection<E>
        定義:
        iterator、インタフェース: Iterable<E>
        定義:
        iterator、クラス: AbstractCollection<E>
        戻り値:
        キュー内の要素を適切な順序で繰返し処理するイテレータ

      • 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である場合