Package io.github.ai4ci.util

Class ThreadSafeArray<X>

java.lang.Object

io.github.ai4ci.util.ThreadSafeArray<X>

Type Parameters:

X - the array type

All Implemented Interfaces:

Serializable

public class ThreadSafeArray<X>
extends Object
implements Serializable

A write once read many times list like data structure. This allows multi-threaded writing to the array and multi-threaded reading and largely assumes they happen in different phases.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ThreadSafeArray.OutOfSpaceException

Constructor Summary

Constructors

Constructor	Description
ThreadSafeArray(Class<X> type, int size)

Method Summary

Modifier and Type	Method	Description
static <Y> ThreadSafeArray<Y>	empty(Class<Y> type)
X[]	finish()
X	get(int p)
boolean	isEmpty()
Stream<X>	parallelStream()
int	put(X value)
int	size()
Stream<X>	stream()

Methods inherited from class java.lang.Object

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

Constructor Details

ThreadSafeArray

public ThreadSafeArray(Class<X> type,
 int size)

Method Details

empty

public static <Y> ThreadSafeArray<Y> empty(Class<Y> type)

put

public int put(X value)

finish

public X[] finish()

get

public X get(int p)

stream

public Stream<X> stream()

parallelStream

public Stream<X> parallelStream()

size

public int size()

isEmpty

public boolean isEmpty()