Most visited

Recently visited

Results for

Added in API level 1

Summary: Ctors | Methods | Inherited Methods | [Expand All]

SynchronousQueue

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

java.lang.Object
↳	java.util.AbstractCollection<E>
	↳	java.util.AbstractQueue<E>
		↳	java.util.concurrent.SynchronousQueue<E>

一个blocking queue ，其中每个插入操作必须等待另一个线程的相应删除操作，反之亦然。同步队列没有任何内部容量，甚至没有一个容量。您不能在同步队列中使用peek ，因为只有在尝试删除元素时才会显示该元素; 除非另一个线程试图删除它，否则不能插入元素（使用任何方法）; 你不能迭代，因为没有什么可以迭代。队列的头部是第一个排队插入线程尝试添加到队列中的元素; 如果没有这样的排队线程，则没有元素可用于移除，并且poll()将返回null 。对于其他Collection方法（例如contains ）而言， SynchronousQueue充当空集合。该队列不允许null元素。

同步队列与CSP和Ada中使用的汇合信道类似。它们非常适合于越区切换设计，其中在一个线程中运行的对象必须与在另一个线程中运行的对象同步，以便交付一些信息，事件或任务。

该类支持订购等待生产者和消费者线程的可选公平策略。默认情况下，这个顺序不能保证。但是，公平性设置为true的队列将按照FIFO顺序授予线程访问权限。

该类及其迭代器实现 Collection和 Iterator接口的所有可选方法。

Summary

Public constructors
`SynchronousQueue()` 使用非公平访问策略创建 `SynchronousQueue` 。
`SynchronousQueue(boolean fair)` 使用指定的公平策略创建一个 `SynchronousQueue` 。

Public methods
`void`	`clear()` 什么也没做。
`boolean`	`contains(Object o)` 始终返回 `false` 。
`boolean`	`containsAll(Collection<?> c)` 除非给定的集合是空的，否则返回 `false` 。
`int`	`drainTo(Collection<? super E> c, int maxElements)` 最多从此队列中移除给定数量的可用元素，并将它们添加到给定集合中。
`int`	`drainTo(Collection<? super E> c)` 从该队列中移除所有可用的元素，并将它们添加到给定的集合中。
`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(long timeout, TimeUnit unit)` 检索并删除此队列的头部，如果需要等待指定的等待时间，则另一个线程将其插入。
`E`	`poll()` 如果另一个线程当前正在创建一个元素，则检索并删除此队列的头部。
`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()` 检索并删除此队列的头部，如果有必要，等待另一个线程插入它。
`<T> T[]`	`toArray(T[] a)` 将指定数组的第零个元素设置为 `null` （如果数组的长度不为零）并将其返回。
`Object[]`	`toArray()` 返回一个零长度的数组。
`String`	`toString()` 始终返回 `"[]"` 。

Inherited methods

From class java.util.AbstractQueue

From class java.util.AbstractCollection

`boolean`	`add(E e)` 确保此集合包含指定的元素（可选操作）。这个实现总是抛出一个 `UnsupportedOperationException` 。
`boolean`	`addAll(Collection<? extends E> c)` 将指定集合中的所有元素添加到此集合（可选操作）。该实现迭代指定的集合，并将迭代器返回的每个对象依次添加到该集合中。
`void`	`clear()` 从该集合中删除所有元素（可选操作）。此实现迭代该集合，使用 `Iterator.remove`操作删除每个元素。
`boolean`	`contains(Object o)` 如果此集合包含指定的元素，则返回 `true` 。该实现迭代集合中的元素，依次检查每个元素是否与指定元素相等。
`boolean`	`containsAll(Collection<?> c)` 如果此集合包含指定集合中的所有元素，则返回 `true` 。此实现迭代指定的集合，依次检查迭代器返回的每个元素，以查看它是否包含在此集合中。
`boolean`	`isEmpty()` 如果此集合不包含元素，则返回 `true` 。该实现返回 `size() == 0` 。
`abstract Iterator<E>`	`iterator()` 返回此集合中包含的元素的迭代器。
`boolean`	`remove(Object o)` 从该集合中移除指定元素的单个实例（如果存在）（可选操作）。该实现迭代查找指定元素的集合。
`boolean`	`removeAll(Collection<?> c)` 删除指定集合中包含的所有此集合的元素（可选操作）。该实现迭代该集合，依次检查迭代器返回的每个元素，以查看它是否包含在指定集合中。
`boolean`	`retainAll(Collection<?> c)` 仅保留包含在指定集合中的此集合中的元素（可选操作）。该实现迭代该集合，依次检查迭代器返回的每个元素，以查看它是否包含在指定集合中。
`abstract int`	`size()` 返回此集合中的元素数量。
`<T> T[]`	`toArray(T[] a)` 返回包含此集合中所有元素的数组; 返回数组的运行时类型是指定数组的运行时类型。该实现返回一个数组，该数组包含由该集合的迭代器以相同顺序返回的所有元素，并存储在数组的连续元素中，从索引 `0`开始。
`Object[]`	`toArray()` 返回包含此集合中所有元素的数组。该实现以索引 `0`开始，以相同的顺序返回一个数组，其中包含由该集合的迭代器返回的所有元素，该数组以相同顺序存储在数组的连续元素中。
`String`	`toString()` 返回此集合的字符串表示形式。

From class java.lang.Object

From interface java.util.Queue

From interface java.util.Collection

`abstract boolean`	`add(E e)` 确保此集合包含指定的元素（可选操作）。
`abstract boolean`	`addAll(Collection<? extends E> c)` 将指定集合中的所有元素添加到此集合（可选操作）。
`abstract void`	`clear()` 从该集合中删除所有元素（可选操作）。
`abstract boolean`	`contains(Object o)` 如果此集合包含指定的元素，则返回 `true` 。
`abstract boolean`	`containsAll(Collection<?> c)` 如果此集合包含指定集合中的所有元素，则返回 `true` 。
`abstract boolean`	`equals(Object o)` 将指定的对象与此集合进行比较以获得相等性。
`abstract int`	`hashCode()` 返回此集合的哈希码值。
`abstract boolean`	`isEmpty()` 如果此集合不包含元素，则返回 `true` 。
`abstract Iterator<E>`	`iterator()` 返回此集合中元素的迭代器。
`default Stream<E>`	`parallelStream()` 返回一个可能与此集合并行的 `Stream`作为其源。
`abstract boolean`	`remove(Object o)` 从该集合中移除指定元素的单个实例（如果存在）（可选操作）。
`abstract boolean`	`removeAll(Collection<?> c)` 删除指定集合中包含的所有此集合的元素（可选操作）。
`default boolean`	`removeIf(Predicate<? super E> filter)` 删除此集合中满足给定谓词的所有元素。
`abstract boolean`	`retainAll(Collection<?> c)` 仅保留包含在指定集合中的此集合中的元素（可选操作）。
`abstract int`	`size()` 返回此集合中的元素数量。
`default Spliterator<E>`	`spliterator()` 在此集合中的元素上创建一个 `Spliterator` 。
`default Stream<E>`	`stream()` 以此集合作为源返回顺序 `Stream` 。
`abstract <T> T[]`	`toArray(T[] a)` 返回包含此集合中所有元素的数组; 返回数组的运行时类型是指定数组的运行时类型。
`abstract Object[]`	`toArray()` 返回包含此集合中所有元素的数组。

From interface java.util.concurrent.BlockingQueue

`abstract boolean`	`add(E e)` 将指定的元素插入此队列中，如果它是立即可行且不会违反容量限制，返回 `true`在成功和抛出 `IllegalStateException` ，如果当前没有空间可用。
`abstract boolean`	`contains(Object o)` 如果此队列包含指定的元素，则返回 `true` 。
`abstract int`	`drainTo(Collection<? super E> c)` 从该队列中移除所有可用的元素，并将它们添加到给定的集合中。
`abstract int`	`drainTo(Collection<? super E> c, int maxElements)` 最多从此队列中移除给定数量的可用元素，并将它们添加到给定集合中。
`abstract boolean`	`offer(E e)` 将指定的元素插入此队列中，如果它是立即可行且不会违反容量限制，返回 `true`在成功和 `false`如果当前没有空间可用。
`abstract boolean`	`offer(E e, long timeout, TimeUnit unit)` 将指定的元素插入此队列中，如有必要，等待指定的等待时间以使空间变为可用。
`abstract E`	`poll(long timeout, TimeUnit unit)` 检索并删除此队列的头部，如果元素变为可用，则等待达到指定的等待时间。
`abstract void`	`put(E e)` 将指定的元素插入此队列，等待空间变得可用时。
`abstract int`	`remainingCapacity()` 如果没有内部限制，则返回此队列理想情况下（在没有内存或资源约束的情况下）接受的附加元素的数量，而不阻止;或者 `Integer.MAX_VALUE` 。
`abstract boolean`	`remove(Object o)` 从该队列中移除指定元素的单个实例（如果存在）。
`abstract E`	`take()` 检索并删除此队列的头部，如果需要等待，直到元素变为可用。

From interface java.lang.Iterable

Public constructors

SynchronousQueue

Added in API level 1

SynchronousQueue ()

使用非公平访问策略创建 SynchronousQueue 。

SynchronousQueue

Added in API level 1

SynchronousQueue (boolean fair)

使用指定的公平策略创建 SynchronousQueue 。

Parameters
`fair`	`boolean`: if true, waiting threads contend in FIFO order for access; otherwise the order is unspecified.

Public methods

clear

Added in API level 1

void clear ()

什么也没做。 A SynchronousQueue没有内部容量。

contains

Added in API level 1

boolean contains (Object o)

始终返回false 。 A SynchronousQueue没有内部容量。

Parameters
`o`	`Object`: the element

Returns
`boolean`	`false`

containsAll

Added in API level 1

boolean containsAll (Collection<?> c)

除非给定的集合是空的，否则返回false 。 A SynchronousQueue没有内部容量。

Parameters
`c`	`Collection`: the collection

Returns
`boolean`	`false` unless given collection is empty

drainTo

Added in API level 1

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

最多从此队列中移除给定数量的可用元素，并将它们添加到给定集合中。尝试将元素添加到集合c遇到的故障可能导致元素不在任何集合中，或者在引发关联异常时集合中的任何一个或两个集合。尝试将队列IllegalArgumentException自身导致IllegalArgumentException 。此外，如果在操作正在进行时修改了指定的集合，则此操作的行为未定义。

Parameters
`c`	`Collection`: the collection to transfer elements into
`maxElements`	`int`: the maximum number of elements to transfer

Returns
`int`	the number of elements transferred

Throws
`UnsupportedOperationException`
`ClassCastException`
`NullPointerException`
`IllegalArgumentException`

drainTo

Added in API level 1

int drainTo (Collection<? super E> c)

从该队列中移除所有可用的元素，并将它们添加到给定的集合中。该操作可能比重复轮询该队列更有效。尝试将元素添加到集合c遇到的故障可能导致元素不在任何集合中，或者在引发关联异常时集合中的任何一个集合或两个集合都不在元素中。尝试将队列IllegalArgumentException自身导致IllegalArgumentException 。此外，如果在操作正在进行时修改了指定的集合，则此操作的行为未定义。

Parameters
`c`	`Collection`: the collection to transfer elements into

Returns
`int`	the number of elements transferred

Throws
`UnsupportedOperationException`
`ClassCastException`
`NullPointerException`
`IllegalArgumentException`

isEmpty

Added in API level 1

boolean isEmpty ()

始终返回true 。 A SynchronousQueue没有内部容量。

Returns
`boolean`	`true`

iterator

Added in API level 1

Iterator<E> iterator ()

返回一个空的迭代器，其中 hasNext始终返回 false 。

Returns
`Iterator<E>`	an empty iterator

offer

Added in API level 1

boolean offer (E e)

如果另一个线程正在等待接收它，则将指定的元素插入此队列中。

Parameters
`e`	`E`: the element to add

Returns
`boolean`	`true` if the element was added to this queue, else `false`

Throws
`NullPointerException`	if the specified element is null

offer

Added in API level 1

boolean offer (E e, 
                long timeout, 
                TimeUnit unit)

将指定的元素插入此队列中，如果需要，可以等待另一个线程接收指定的元素。

Parameters
`e`	`E`: the element to add
`timeout`	`long`: how long to wait before giving up, in units of `unit`
`unit`	`TimeUnit`: a `TimeUnit` determining how to interpret the `timeout` parameter

Returns
`boolean`	`true` if successful, or `false` if the specified waiting time elapses before a consumer appears

Throws
`InterruptedException`
`NullPointerException`

peek

Added in API level 1

E peek ()

始终返回null 。除非主动等待，否则SynchronousQueue不会返回元素。

Returns
`E`	`null`

poll

Added in API level 1

E poll (long timeout, 
                TimeUnit unit)

检索并删除此队列的头部，如果需要等待指定的等待时间，则另一个线程将其插入。

Parameters
`timeout`	`long`: how long to wait before giving up, in units of `unit`
`unit`	`TimeUnit`: a `TimeUnit` determining how to interpret the `timeout` parameter

Returns
`E`	the head of this queue, or `null` if the specified waiting time elapses before an element is present

Throws
`InterruptedException`

poll

Added in API level 1

E poll ()

如果另一个线程当前正在创建一个元素，则检索并删除此队列的头部。

Returns
`E`	the head of this queue, or `null` if no element is available

put

Added in API level 1

void put (E e)

将指定的元素添加到此队列中，等待其他线程接收它。

Parameters
`e`	`E`: the element to add

Throws
`InterruptedException`
`NullPointerException`

remainingCapacity

Added in API level 1

int remainingCapacity ()

始终返回零。 A SynchronousQueue没有内部容量。

Returns
`int`	zero

remove

Added in API level 1

boolean remove (Object o)

始终返回false 。 A SynchronousQueue没有内部容量。

Parameters
`o`	`Object`: the element to remove

Returns
`boolean`	`false`

removeAll

Added in API level 1

boolean removeAll (Collection<?> c)

总是返回false 。 A SynchronousQueue没有内部容量。

Parameters
`c`	`Collection`: the collection

Returns
`boolean`	`false`

retainAll

Added in API level 1

boolean retainAll (Collection<?> c)

始终返回false 。 A SynchronousQueue没有内部容量。

Parameters
`c`	`Collection`: the collection

Returns
`boolean`	`false`

size

Added in API level 1

int size ()

始终返回零。 A SynchronousQueue没有内部容量。

Returns
`int`	zero

spliterator

Added in API level 24

Spliterator<E> spliterator ()

返回一个空分隔符，其中调用 trySplit()始终返回 null 。

Returns
`Spliterator<E>`	an empty spliterator

take

Added in API level 1

E take ()

检索并删除此队列的头部，如果有必要，等待另一个线程插入它。

Returns
`E`	the head of this queue

Throws
`InterruptedException`

toArray

Added in API level 1

T[] toArray (T[] a)

将指定数组的第零个元素设置为 null （如果该数组的长度不为零）并将其返回。

Parameters
`a`	`T`: the array

Returns
`T[]`	the specified array

Throws
`NullPointerException`	if the specified array is null

toArray

Added in API level 1

Object[] toArray ()

返回一个零长度的数组。

Returns
`Object[]`	a zero-length array

toString

Added in API level 1

String toString ()

始终返回 "[]" 。

Returns
`String`	`"[]"`

Interfaces

Classes

Enums

Exceptions

Most visited

Recently visited

Results for

SynchronousQueue

Summary

Public constructors

Public methods

Inherited methods

Public constructors

SynchronousQueue

SynchronousQueue

Public methods

clear

contains

containsAll

drainTo

drainTo

isEmpty

iterator

offer

offer

peek

poll

poll

put

remainingCapacity

remove

removeAll

retainAll

size

spliterator

take

toArray

toArray

toString