com.bigdata.relation.rule.eval.pipeline

Class JoinTask.ThreadLocalFactory<T extends IBuffer<E>,E>

java.lang.Object

com.bigdata.relation.rule.eval.pipeline.JoinTask.ThreadLocalFactory<T,E>

Type Parameters:

T - The generic type of the thread-local object.

Enclosing class:

JoinTask

public abstract class JoinTask.ThreadLocalFactory<T extends IBuffer<E>,E>
extends Object

A factory pattern for per-thread objects whose life cycle is tied to some container. For example, there may be an instance of this pool for a JoinTask or an AbstractBTree. The pool can be torn down when the container is torn down, which prevents its thread-local references from escaping.

Author:

thompsonbry@users.sourceforge.net

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JoinTask.ThreadLocalFactory()
protected	JoinTask.ThreadLocalFactory(int initialCapacity, float loadFactor, int concurrencyLevel)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(E e) Add the element to the thread-local buffer.
void	flush() Flush each of the unsynchronized buffers onto their backing synchronized buffer.
protected abstract T	initialValue() Create and return a new object.
void	reset() Reset each of the synchronized buffers, discarding their buffered writes.
int	size() Return the #of thread-local objects.

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinTask.ThreadLocalFactory

protected JoinTask.ThreadLocalFactory()

JoinTask.ThreadLocalFactory

protected JoinTask.ThreadLocalFactory(int initialCapacity,
                           float loadFactor,
                           int concurrencyLevel)

Method Detail

size

public final int size()

Return the #of thread-local objects.

add

public void add(E e)

Add the element to the thread-local buffer.

Parameters:

e - An element.

Throws:

IllegalStateException - if the factory is asynchronously closed.

flush

public void flush()

Flush each of the unsynchronized buffers onto their backing synchronized buffer.

Throws:

RuntimeException - if the join is halted.

reset

public void reset()

Reset each of the synchronized buffers, discarding their buffered writes.

Note: This method is used during error processing, therefore it DOES NOT check JoinTask.halt.

initialValue

protected abstract T initialValue()

Create and return a new object.