Package ru.progrm_jarvis.javacommons.collection.concurrent

Class ConcurrentCollectionWrapper<E,W extends Collection<E>>

java.lang.Object

ru.progrm_jarvis.javacommons.collection.concurrent.ConcurrentWrapper<W>

ru.progrm_jarvis.javacommons.collection.concurrent.AbstractConcurrentSizedCollectionWrapper<W>

ru.progrm_jarvis.javacommons.collection.concurrent.ConcurrentCollectionWrapper<E,W>

All Implemented Interfaces:

Iterable<E>, Collection<E>, SizedCollection

Direct Known Subclasses:

ConcurrentListWrapper, ConcurrentQueueWrapper, ConcurrentSetWrapper

public class ConcurrentCollectionWrapper<E,W extends Collection<E>>
extends AbstractConcurrentSizedCollectionWrapper<W>
implements Collection<E>

Field Summary

Fields inherited from class ru.progrm_jarvis.javacommons.collection.concurrent.ConcurrentWrapper

readLock, wrapped, writeLock

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConcurrentCollectionWrapper(W wrapped, @NotNull Lock readLock, @NotNull Lock writeLock)

Method Summary

Modifier and Type	Method	Description
boolean	add(E e)
boolean	addAll(@NonNull Collection<? extends E> elements)
boolean	contains(Object o)
boolean	containsAll(@NonNull Collection<?> elements)
static <E> @NotNull Collection<E>	create(@NonNull Collection<E> wrapped)
void	forEach(@NonNull Consumer<? super E> action)
protected void	internalClear()
protected boolean	internalIsEmpty()
protected int	internalSize()
@NotNull Iterator<E>	iterator()
Stream<E>	parallelStream()
boolean	remove(Object o)
boolean	removeAll(@NonNull Collection<?> elements)
boolean	removeIf(@NonNull Predicate<? super E> filter)
boolean	retainAll(@NonNull Collection<?> elements)
Spliterator<E>	spliterator()
Stream<E>	stream()
@NotNull Object @NotNull []	toArray()
<R> @NotNull R[]	toArray(R @NonNull [] targetArray)

Methods inherited from class ru.progrm_jarvis.javacommons.collection.concurrent.AbstractConcurrentSizedCollectionWrapper

clear, isEmpty, size

Methods inherited from class ru.progrm_jarvis.javacommons.collection.concurrent.ConcurrentWrapper

equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

clear, equals, hashCode, isEmpty, size

Constructor Details

ConcurrentCollectionWrapper

protected ConcurrentCollectionWrapper(@NotNull
 W wrapped,
 @NotNull
 @NotNull Lock readLock,
 @NotNull
 @NotNull Lock writeLock)

Method Details

create

@NotNull
public static <E> @NotNull Collection<E> create(@NonNull
 @NonNull Collection<E> wrapped)

internalSize

protected int internalSize()

Specified by:

internalSize in class AbstractConcurrentSizedCollectionWrapper<W extends Collection<E>>

internalIsEmpty

protected boolean internalIsEmpty()

Specified by:

internalIsEmpty in class AbstractConcurrentSizedCollectionWrapper<W extends Collection<E>>

internalClear

protected void internalClear()

Specified by:

internalClear in class AbstractConcurrentSizedCollectionWrapper<W extends Collection<E>>

contains

public boolean contains(Object o)

Specified by:

contains in interface Collection<E>

iterator

@NotNull
public @NotNull Iterator<E> iterator()

Specified by:

iterator in interface Collection<E>

Specified by:

iterator in interface Iterable<E>

toArray

@NotNull
public @NotNull Object @NotNull [] toArray()

Specified by:

toArray in interface Collection<E>

toArray

@NotNull
public <R> @NotNull R[] toArray(R @NonNull [] targetArray)

Specified by:

toArray in interface Collection<E>

add

public boolean add(E e)

Specified by:

add in interface Collection<E>

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<E>

containsAll

public boolean containsAll(@NonNull
 @NonNull Collection<?> elements)

Specified by:

containsAll in interface Collection<E>

addAll

public boolean addAll(@NonNull
 @NonNull Collection<? extends E> elements)

Specified by:

addAll in interface Collection<E>

removeAll

public boolean removeAll(@NonNull
 @NonNull Collection<?> elements)

Specified by:

removeAll in interface Collection<E>

removeIf

public boolean removeIf(@NonNull
 @NonNull Predicate<? super E> filter)

Specified by:

removeIf in interface Collection<E>

retainAll

public boolean retainAll(@NonNull
 @NonNull Collection<?> elements)

Specified by:

retainAll in interface Collection<E>

spliterator

public Spliterator<E> spliterator()

Specified by:

spliterator in interface Collection<E>

Specified by:

spliterator in interface Iterable<E>

stream

public Stream<E> stream()

Specified by:

stream in interface Collection<E>

parallelStream

public Stream<E> parallelStream()

Specified by:

parallelStream in interface Collection<E>

forEach

public void forEach(@NonNull
 @NonNull Consumer<? super E> action)

Specified by:

forEach in interface Iterable<E>