com.jn.langx.util.collection

类 ConcurrentCyclicSequence<T>

java.lang.Object

com.jn.langx.util.collection.ConcurrentCyclicSequence<T>

所有已实现的接口:

Iterable<T>, Iterator<T>

public class ConcurrentCyclicSequence<T>
extends Object
implements Iterable<T>, Iterator<T>

A concurrent cyclic sequence of elements that can be used for round robin.

The sequence is immutable and modifications are done with copy-on-write using add(Object) and remove(Object) to return a modified copy of the current instance.

The internal counter uses a volatile index, so it can be incremented concurrently by several threads without locking.

从以下版本开始:

4.1.0

构造器概要

构造器

构造器和说明
ConcurrentCyclicSequence() Create a new empty sequence.
ConcurrentCyclicSequence(T... elements) Create a new empty sequence.

方法概要

限定符和类型	方法和说明
ConcurrentCyclicSequence<T>	add(T element) Copy the current sequence, add element at the tail of this sequence and returns it.
T	first()
boolean	hasNext()
int	index()
Iterator<T>	iterator()
T	next()
void	remove()
ConcurrentCyclicSequence<T>	remove(T element) Remove the first occurrence of element in this sequence and returns it.
int	size()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 java.lang.Iterable

forEach, spliterator

从接口继承的方法 java.util.Iterator

forEachRemaining

构造器详细资料

ConcurrentCyclicSequence

public ConcurrentCyclicSequence()

Create a new empty sequence.

ConcurrentCyclicSequence

public ConcurrentCyclicSequence(T... elements)

Create a new empty sequence.

方法详细资料

index

public int index()

返回:

the current index

first

public T first()

返回:

the first element or null when the sequence is empty

add

public ConcurrentCyclicSequence<T> add(T element)

Copy the current sequence, add element at the tail of this sequence and returns it.

参数:

element - the element to add

返回:

the resulting sequence

remove

public ConcurrentCyclicSequence<T> remove(T element)

Remove the first occurrence of element in this sequence and returns it.

If the sequence does not contains element, this instance is returned instead.

参数:

element - the element to remove

返回:

the resulting sequence

remove

public void remove()

指定者:

remove 在接口中 Iterator<T>

hasNext

public boolean hasNext()

指定者:

hasNext 在接口中 Iterator<T>

返回:

always true

next

public T next()

指定者:

next 在接口中 Iterator<T>

返回:

the next element in the sequence

size

public int size()

返回:

the size of this sequence

iterator

public Iterator<T> iterator()

指定者:

iterator 在接口中 Iterable<T>

返回:

an iterator starting at the first element of the sequence, the iterator will not throw ConcurrentModificationException