com.numericalmethod.suanshu.stats.random.concurrent

Class ConcurrentCachedGenerator<T>

java.lang.Object

com.numericalmethod.suanshu.stats.random.concurrent.ConcurrentCachedGenerator<T>

Type Parameters:

T - the type of the item

All Implemented Interfaces:

java.io.Serializable

public class ConcurrentCachedGenerator<T>
extends java.lang.Object
implements java.io.Serializable

A generic wrapper that makes an underlying item generator thread-safe by caching generated items in a concurrently-accessible list. This is more efficient than plainly synchronizing all accessors of the generator.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ConcurrentCachedGenerator.Generator<T> Defines a generic generator of type T.

Constructor Summary

Constructors

Constructor and Description
ConcurrentCachedGenerator(ConcurrentCachedGenerator.Generator<T> generator, int cacheSize) Creates a new instance which wraps the given item generator and uses a cache of the specified size.

Method Summary

Modifier and Type	Method and Description
T	next() Returns the next value in the generated sequence.
void	readObject(java.io.ObjectInputStream ois)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentCachedGenerator

public ConcurrentCachedGenerator(ConcurrentCachedGenerator.Generator<T> generator,
                                 int cacheSize)

Creates a new instance which wraps the given item generator and uses a cache of the specified size. A larger cache will make the concurrency slightly faster at the expense of increased memory usage, but may lead to the computation of unnecessary values at the tail.

Parameters:

generator - the underlying generator

cacheSize - the size of the cache

Method Detail

next

public T next()

Returns the next value in the generated sequence.

Returns:

the next generated value

readObject

public void readObject(java.io.ObjectInputStream ois)
                throws java.io.IOException,
                       java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException