模块  java.base
软件包  java.util.concurrent

Class LinkedTransferQueue<E>

    • 构造方法详细信息

      • LinkedTransferQueue

        public LinkedTransferQueue()
        创建一个最初为空的 LinkedTransferQueue
      • LinkedTransferQueue

        public LinkedTransferQueue​(Collection<? extends E> c)
        创建一个最初包含给定集合元素的 LinkedTransferQueue ,以集合迭代器的遍历顺序添加。
        参数
        c - 最初包含的元素集合
        异常
        NullPointerException - 如果指定的集合或其任何元素为null
    • 方法详细信息

      • toArray

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

        返回的数组将是“安全的”,因为此队列不会保留对它的引用。 (换句话说,此方法必须分配一个新数组)。 因此调用者可以自由修改返回的数组。

        此方法充当基于阵列和基于集合的API之间的桥梁。

        Specified by:
        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()相同。
        Specified by:
        toArray在界面 Collection<E>
        重写:
        toArray在类 AbstractCollection<E>
        参数类型
        T - 要包含集合的数组的组件类型
        参数
        a - 要存储队列元素的数组(如果足够大); 否则,为此目的分配相同运行时类型的新数组
        结果
        包含此队列中所有元素的数组
        异常
        ArrayStoreException - 如果指定数组的运行时类型不是此队列中每个元素的运行时类型的超类型
        NullPointerException - 如果指定的数组为null
      • put

        public void put​(E e)
        将指定元素插入此队列的尾部。 由于队列是无限制的,因此该方法永远不会阻塞。
        Specified by:
        put ,界面 BlockingQueue<E>
        参数
        e - 要添加的元素
        异常
        NullPointerException - 如果指定的元素为null
      • offer

        public boolean offer​(E e,
                             long timeout,
                             TimeUnit unit)
        将指定元素插入此队列的尾部。 由于队列无限制,此方法永远不会阻止或返回false
        Specified by:
        offer ,界面 BlockingQueue<E>
        参数
        e - 要添加的元素
        timeout - 放弃前等待多长时间,单位为 unit
        unit -一个 TimeUnit确定如何解释 timeout参数
        结果
        true (由 BlockingQueue.offer指定)
        异常
        NullPointerException - 如果指定的元素为null
      • offer

        public boolean offer​(E e)
        将指定元素插入此队列的尾部。 由于队列无限制,此方法永远不会返回false
        Specified by:
        offer在界面 BlockingQueue<E>
        Specified by:
        offer在界面 Queue<E>
        参数
        e - 要添加的元素
        结果
        true (由 Queue.offer(E)指定)
        异常
        NullPointerException - 如果指定的元素为null
      • tryTransfer

        public boolean tryTransfer​(E e)
        如果可能,立即将元素转移给等待的消费者。

        更确切地说,如果存在已经等待接收它的消费者(在BlockingQueue.take()或定时poll ),则立即传送指定元素,否则返回false而不将该元素排队。

        Specified by:
        tryTransfer在接口 TransferQueue<E>
        参数
        e - 要转移的元素
        结果
        true如果元素已转移, false
        异常
        NullPointerException - 如果指定的元素为null
      • transfer

        public void transfer​(E e)
                      throws InterruptedException
        将元素传输给消费者,在必要时等待。

        更确切地说,如果存在已经等待接收它的消费者(在BlockingQueue.take()或定时poll ),则立即传送指定的元素,否则在该队列的尾部插入指定的元素并等待消费者接收该元素。

        Specified by:
        transfer在界面 TransferQueue<E>
        参数
        e - 要转移的元素
        异常
        NullPointerException - 如果指定的元素为null
        InterruptedException - 如果在等待时被中断,在这种情况下该元素不会被排队
      • tryTransfer

        public boolean tryTransfer​(E e,
                                   long timeout,
                                   TimeUnit unit)
                            throws InterruptedException
        如果可以在超时过去之前执行此操作,则将元素传输给使用者。

        更确切地说,如果存在已经等待接收它的消费者(在BlockingQueue.take()或定时poll ),则立即传送指定的元素,否则在该队列的尾部插入指定的元素并等待消费者接收该元素,返回false如果在传输元素之前经过了指定的等待时间。

        Specified by:
        tryTransfer在界面 TransferQueue<E>
        参数
        e - 要转移的元素
        timeout - 放弃前等待多长时间,单位为 unit
        unit -一个 TimeUnit确定如何解释 timeout参数
        结果
        true如果成功,或 false如果指定的等待时间在完成之前过去,在这种情况下该元素不会被排队
        异常
        NullPointerException - 如果指定的元素为null
        InterruptedException - 如果在等待时被中断,则在这种情况下该元素不会被排队
      • drainTo

        public int drainTo​(Collection<? super E> c)
        从界面复制的说明: BlockingQueue
        从此队列中删除所有可用元素,并将它们添加到给定集合中。 此操作可能比重复轮询此队列更有效。 尝试将元素添加到集合c遇到的故障可能导致在抛出关联的异常时元素既不在集合中,也不在集合中。 尝试将队列排入自身会导致IllegalArgumentException 此外,如果在操作正在进行时修改了指定的集合,则此操作的行为是不确定的。
        Specified by:
        drainTo in interface BlockingQueue<E>
        参数
        c - 将元素转换为的集合
        结果
        转移的元素数量
        异常
        NullPointerException - 如果指定的集合为null
        IllegalArgumentException - 如果指定的集合是此队列,或此队列的某个元素的某些属性阻止将其添加到指定的集合
      • drainTo

        public int drainTo​(Collection<? super E> c,
                           int maxElements)
        从界面复制的说明: BlockingQueue
        从该队列中删除最多给定数量的可用元素,并将它们添加到给定集合中。 尝试向集合c添加元素时遇到的故障可能导致在抛出关联的异常时元素既不在集合中,也不在集合中。 尝试将队列排入自身会导致IllegalArgumentException 此外,如果在操作正在进行时修改了指定的集合,则此操作的行为是不确定的。
        Specified by:
        drainTo在界面 BlockingQueue<E>
        参数
        c - 将元素转移到的集合
        maxElements - 要传输的最大元素数
        结果
        转移的元素数量
        异常
        NullPointerException - 如果指定的集合为null
        IllegalArgumentException - 如果指定的集合是此队列,或此队列的某个元素的某些属性阻止将其添加到指定的集合
      • isEmpty

        public boolean isEmpty()
        如果此队列不包含任何元素,则返回 true
        Specified by:
        isEmpty在接口 Collection<E>
        重写:
        isEmpty在类 AbstractCollection<E>
        结果
        true如果此队列不包含任何元素
      • size

        public int size()
        返回此队列中的元素数。 如果此队列包含超过Integer.MAX_VALUE元素,则返回Integer.MAX_VALUE

        请注意,与大多数集合不同,此方法不是恒定时间操作。 由于这些队列的异步性质,确定当前元素数需要O(n)遍历。

        Specified by:
        size在界面 Collection<E>
        结果
        此队列中的元素数
      • remove

        public boolean remove​(Object o)
        从此队列中删除指定元素的单个实例(如果存在)。 更正式地,如果此队列包含一个或多个此类元素,则删除元素e ,使得o.equals(e) 如果此队列包含指定的元素,则返回true (或等效地,如果此队列因调用而更改)。
        Specified by:
        remove在接口 BlockingQueue<E>
        Specified by:
        remove在界面 Collection<E>
        重写:
        remove在类 AbstractCollection<E>
        参数
        o - 要从此队列中删除的元素(如果存在)
        结果
        true如果此队列因调用而更改
      • contains

        public boolean contains​(Object o)
        如果此队列包含指定的元素,则返回true 更正式的,返回true当且仅当此队列包含至少一个元素e这样o.equals(e)
        Specified by:
        contains在界面 BlockingQueue<E>
        Specified by:
        contains在界面 Collection<E>
        重写:
        contains在类 AbstractCollection<E>
        参数
        o - 要在此队列中检查包含的对象
        结果
        true如果此队列包含指定的元素
      • removeIf

        public boolean removeIf​(Predicate<? super E> filter)
        从界面复制的说明: Collection
        删除此集合中满足给定谓词的所有元素。 在迭代期间或通过谓词抛出的错误或运行时异常被中继到调用者。
        Specified by:
        removeIf in interface Collection<E>
        参数
        filter - 一个谓词,它返回 true表示要删除的元素
        结果
        true是否删除了任何元素
        异常
        NullPointerException - 如果指定的过滤器为null
      • forEach

        public void forEach​(Consumer<? super E> action)
        从界面复制的说明: Iterable
        Iterable每个元素执行给定操作,直到处理Iterable所有元素或操作抛出异常为止。 如果指定了该顺序,则按迭代顺序执行操作。 操作抛出的异常将转发给调用者。

        如果操作执行修改元素的基础源的副作用,则此方法的行为未指定,除非重写类已指定并发修改策略。

        Specified by:
        forEach在界面 Iterable<E>
        参数
        action - 要为每个元素执行的操作
        异常
        NullPointerException - if the specified action is null