A B C E F G H I J K L P R S T U V

A

AbstractLogEqLock<OBJ_T,LOCK_T> - Class in jconch.lock

Provides the basic implementation for logically equivalent locks.

AbstractLogEqLock() - Constructor for class jconch.lock.AbstractLogEqLock

add(T) - Method in class jconch.pipeline.PipeLink

Adds an element into the link, if at all possible.

asTransformer() - Method in class jconch.cache.CacheMap

Provides access to this object as a Transformer.

attachConsumer(Consumer<CURRENT_T>) - Method in class jconch.pipeline.builder.PipelineBuilder

Attaches a consumer onto the end of the pipeline.

attachProcessor(Processor<CURRENT_T, NEW_T>) - Method in class jconch.pipeline.builder.PipelineBuilder

Attaches a processor onto the end of the pipeline.

B

BoundedPipeLink<T> - Class in jconch.pipeline.impl

A pipe link with a specified upper bound on the queue length.

BoundedPipeLink(int) - Constructor for class jconch.pipeline.impl.BoundedPipeLink

Constructor.

breakLink() - Method in class jconch.pipeline.PipeLink

Breaks the link completely and permanently.

C

CacheMap<KEY_T,VAL_T> - Class in jconch.cache

A map that provides cached look-ups in a thread-safe manner.

CacheMap(Transformer) - Constructor for class jconch.cache.CacheMap

Constructs a new instance of the cache map.

CacheMap(Transformer, SyncLogEqLock<KEY_T>) - Constructor for class jconch.cache.CacheMap

Constructs a new instance of the cache map.

clear() - Method in class jconch.cache.CacheMap

Clears the cache.

clearQueue() - Method in class jconch.pipeline.PipeLink

Drops all elements from this link.

ClosureConsumer - Class in jconch.pipeline.impl

A Closure-based implementation of a Consumer.

ClosureConsumer(Closure, ThreadingModel, PipeLink) - Constructor for class jconch.pipeline.impl.ClosureConsumer

Constructor.

CollectionConsumer<T> - Class in jconch.pipeline.impl

A consumer which collects elements into a collection.

CollectionConsumer(ThreadingModel, PipeLink<T>) - Constructor for class jconch.pipeline.impl.CollectionConsumer

CollectionConsumer(Collection<T>, ThreadingModel, PipeLink<T>) - Constructor for class jconch.pipeline.impl.CollectionConsumer

Constructor.

CollectionProducer<T> - Class in jconch.pipeline.impl

A producer which provides elements from a given collection.

CollectionProducer(Collection<T>, ThreadingModel, PipeLink<T>) - Constructor for class jconch.pipeline.impl.CollectionProducer

Constructor.

consumeItem(T) - Method in class jconch.pipeline.Consumer

Responsible for consuming items.

consumeItem(Object) - Method in class jconch.pipeline.impl.ClosureConsumer

Delegates implementation to Closure.execute(Object).

consumeItem(T) - Method in class jconch.pipeline.impl.CollectionConsumer

Consumer<T> - Class in jconch.pipeline

The base implementation of a pipe that consumes elements without producing anything.

Consumer(ThreadingModel, PipeLink<T>) - Constructor for class jconch.pipeline.Consumer

Creates a new instance of Consumer.

containsKey(Object) - Method in class jconch.cache.CacheMap

Determines whether the value for the current key is in cache.

containsValue(Object) - Method in class jconch.cache.CacheMap

Whether the value is in the cache.

createNewLock() - Method in class jconch.lock.AbstractLogEqLock

Implementation of the "lock" that is created.

createNewLock() - Method in class jconch.lock.RWLogEqLock

createNewLock() - Method in class jconch.lock.SyncLogEqLock

E

entrySet() - Method in class jconch.cache.CacheMap

Provides the set of cached values.

equals(Object) - Method in class jconch.cache.CacheMap

Determines equality based on cached operation definition.

ExceptionThreadingModel - Class in jconch.pipeline.impl

Class that explodes when ExceptionThreadingModel.execute(PipelineStage) is called.

ExceptionThreadingModel() - Constructor for class jconch.pipeline.impl.ExceptionThreadingModel

execute() - Method in class jconch.pipeline.Consumer

Fetches an object and calls Consumer.consumeItem(Object) on it.

execute(PipelineStage) - Method in class jconch.pipeline.impl.ExceptionThreadingModel

execute(PipelineStage) - Method in class jconch.pipeline.impl.ExecutorThreadingModel

Delegates the execution of the argument to the underlying executor.

execute(PipelineStage) - Method in class jconch.pipeline.impl.InlineThreadingModel

Simply calls PipelineStage.execute().

execute(PipelineStage) - Method in class jconch.pipeline.impl.SingleThreadThreadingModel

Spawns a thread, and it keeps executing everything.

execute(PipelineStage) - Method in class jconch.pipeline.impl.SpawningThreadingModel

Spawns a thread that calls PipelineStage.execute().

execute() - Method in class jconch.pipeline.PipelineStage

Executes one round of processing for this pipeline stage.

execute() - Method in class jconch.pipeline.Processor

execute() - Method in class jconch.pipeline.Producer

Checks state, generates an element, and then puts it into the queue.

execute(PipelineStage) - Method in interface jconch.pipeline.ThreadingModel

Wraps the execution of the pipeline in the appropriate threading.

ExecutorThreadingModel - Class in jconch.pipeline.impl

A wrapper around ThreadingModel which allows the user to leverage the Executor API, and its myriad extensions.

ExecutorThreadingModel(Executor) - Constructor for class jconch.pipeline.impl.ExecutorThreadingModel

Constructor.

F

FactoryProducer - Class in jconch.pipeline.impl

A Producer based off of a Factory implementation.

FactoryProducer(Factory, ThreadingModel, PipeLink) - Constructor for class jconch.pipeline.impl.FactoryProducer

Constructor.

finalize() - Method in class jconch.pipeline.impl.ExecutorThreadingModel

G

get(Object) - Method in class jconch.cache.CacheMap

Gets the value for the given object.

get() - Method in class jconch.pipeline.PipeLink

Removes an element from the link, if any is available.

getAddTimeout() - Method in class jconch.pipeline.PipeLink

Gets the timeout on add operations of the instance.

getCollection() - Method in class jconch.pipeline.impl.CollectionConsumer

Gets the collection backing the instance.

getCollection() - Method in class jconch.pipeline.impl.CollectionProducer

Gets the collection backing the instance.

getFetchTimeout() - Method in class jconch.pipeline.PipeLink

Gets the timeout on fetch operations of the instance.

getGlobalInstance() - Static method in class jconch.lock.RWLogEqLock

Provides the same instance of this class every time.

getGlobalInstance() - Static method in class jconch.lock.SyncLogEqLock

Provides the same instance of this class every time it is called.

getLink() - Method in class jconch.pipeline.builder.PipelineBuilder

Gets the link of the instance.

getLinkIn() - Method in class jconch.pipeline.Consumer

Provides the pipe link that is being drawn from.

getLinkIn() - Method in class jconch.pipeline.Processor

Provides the pipe link that is being drawn from.

getLinkOut() - Method in class jconch.pipeline.Processor

Provides the pipeline link out.

getLinkOut() - Method in class jconch.pipeline.Producer

Provides the pipeline link out.

getLock(OBJ_T) - Method in class jconch.lock.AbstractLogEqLock

Provides a lock for the given object.

getQueueLength() - Method in class jconch.pipeline.PipeLink

Provides the number of elements currently in the queue.

getRemainingCapacity() - Method in class jconch.pipeline.impl.UnboundedPipeLink

Have to override this because LinkedBlockingQueue.remainingCapacity() doesn't work as expected -- apparently an unbounded queue runs low on space after you insert elements.

getRemainingCapacity() - Method in class jconch.pipeline.PipeLink

Provides an estimate of the number of elements the queue could additionally hold.

getSpawnPeriod() - Method in class jconch.pipeline.impl.ExecutorThreadingModel

Gets the period between executor calls for instance.

getSpawnPeriod() - Method in class jconch.pipeline.impl.SpawningThreadingModel

getThreadingModel() - Method in class jconch.pipeline.builder.PipelineBuilder

Gets the threading model of the element which was last attached.

getThreadingModel() - Method in class jconch.pipeline.PipelineStage

Gets the threading model of the instance.

getTransformer() - Method in class jconch.cache.CacheMap

Provides the underlying cache operation.

H

hashCode() - Method in class jconch.cache.CacheMap

Provides the hash code based on the cached operation definition.

hasLockFor(OBJ_T) - Method in class jconch.lock.AbstractLogEqLock

Determines if we have a lock for the given object currently at hand.

I

InlineThreadingModel - Class in jconch.pipeline.impl

Executes the pipeline stage inline.

InlineThreadingModel() - Constructor for class jconch.pipeline.impl.InlineThreadingModel

isEmpty() - Method in class jconch.cache.CacheMap

Determines if there is anything in the cache.

isExhausted() - Method in class jconch.pipeline.impl.CollectionProducer

Determines if the producer is done producing elements.

isExhausted() - Method in class jconch.pipeline.impl.FactoryProducer

isExhausted() - Method in class jconch.pipeline.Producer

Determines if the pipeline stage will not produce any more elements.

isFinished() - Method in class jconch.pipeline.Consumer

In addition to the super implementation, it checks for error conditions.

isFinished() - Method in class jconch.pipeline.PipelineStage

If the pipeline is not supposed to handle any more elements, either because of an error or because a producer is exhausted.

isFinished() - Method in class jconch.pipeline.Processor

isFinished() - Method in class jconch.pipeline.Producer

In addition to the basic checks, checks for error conditions.

isStarted() - Method in class jconch.pipeline.PipelineStage

Whether this pipline stage has been started or not.

J

jconch.cache - package jconch.cache

jconch.lock - package jconch.lock

jconch.pipeline - package jconch.pipeline

jconch.pipeline.builder - package jconch.pipeline.builder

jconch.pipeline.impl - package jconch.pipeline.impl

K

keySet() - Method in class jconch.cache.CacheMap

The set of keys currently loaded into the cache.

L

link - Variable in class jconch.pipeline.Producer

The link we drop into.

logMessage(String, Exception) - Method in class jconch.pipeline.PipelineStage

Called when an exception occurs in execution.

P

PipelineBuilder<CURRENT_T> - Class in jconch.pipeline.builder

Class for programmatically building up a pipeline.

PipelineBuilder(Producer<CURRENT_T>) - Constructor for class jconch.pipeline.builder.PipelineBuilder

Constructor.

PipelineStage - Class in jconch.pipeline

The base interface for a stage in the pipeline.

PipelineStage(ThreadingModel) - Constructor for class jconch.pipeline.PipelineStage

Constructor.

PipeLink<T> - Class in jconch.pipeline

A link in the stages of the pipeline.

PipeLink(BlockingQueue<T>) - Constructor for class jconch.pipeline.PipeLink

Constructor.

process(Object) - Method in class jconch.pipeline.impl.TransformerProcessor

Delegates the implemenation to Transformer.transform(Object).

process(IN_T) - Method in class jconch.pipeline.Processor

The argument that implements the processing for this class.

Processor<IN_T,OUT_T> - Class in jconch.pipeline

A processing pipe in the pipeline.

Processor(ThreadingModel, PipeLink<IN_T>, PipeLink<OUT_T>) - Constructor for class jconch.pipeline.Processor

Creates a new intance of Processor.

produceItem() - Method in class jconch.pipeline.impl.CollectionProducer

produceItem() - Method in class jconch.pipeline.impl.FactoryProducer

produceItem() - Method in class jconch.pipeline.Producer

Method that must be implemented to queue the producer.

Producer<OUT_T> - Class in jconch.pipeline

The base implementation of a pipe that produces new elements to retrieve.

Producer(ThreadingModel, PipeLink<OUT_T>) - Constructor for class jconch.pipeline.Producer

Constructor.

put(KEY_T, VAL_T) - Method in class jconch.cache.CacheMap

Sets key to map to value in this map.

putAll(Map<? extends KEY_T, ? extends VAL_T>) - Method in class jconch.cache.CacheMap

Copies all of the giving mappings into the cache.

R

registerSource(Producer<T>) - Method in class jconch.pipeline.PipeLink

Registers a source for this pipe link.

remove(Object) - Method in class jconch.cache.CacheMap

Removes an object from the cache.

RWLogEqLock<OBJ_T> - Class in jconch.lock

Class that provides ReadWriteLock instances tagged by logically equivalent objects.

RWLogEqLock() - Constructor for class jconch.lock.RWLogEqLock

Constructor.

S

setAddTimeout(long) - Method in class jconch.pipeline.PipeLink

Sets the add timeout of the instance.

setFetchTimeout(long) - Method in class jconch.pipeline.PipeLink

Sets the fetch timeout of the instance.

setSpawnDelay(long) - Method in class jconch.pipeline.impl.ExecutorThreadingModel

Sets the period between executor calls for instance.

setSpawnPeriod(long) - Method in class jconch.pipeline.impl.SpawningThreadingModel

SingleThreadThreadingModel - Class in jconch.pipeline.impl

Runs a single different thread to process the threading.

SingleThreadThreadingModel() - Constructor for class jconch.pipeline.impl.SingleThreadThreadingModel

size() - Method in class jconch.cache.CacheMap

Provides the size of the cache at the moment.

SpawningThreadingModel - Class in jconch.pipeline.impl

Spawns a new thread for each call to execute.

SpawningThreadingModel() - Constructor for class jconch.pipeline.impl.SpawningThreadingModel

Constructor that uses a default wait time between spawns.

SpawningThreadingModel(long) - Constructor for class jconch.pipeline.impl.SpawningThreadingModel

Constructor.

start() - Method in class jconch.pipeline.PipelineStage

Starts the pipeline within its threading model.

SyncLogEqLock<OBJ_T> - Class in jconch.lock

This class should be used to implement logically equivalent locks.

SyncLogEqLock() - Constructor for class jconch.lock.SyncLogEqLock

Default constructor.

T

ThreadingModel - Interface in jconch.pipeline

Implements a threading model for a pipeline.

TransformerProcessor - Class in jconch.pipeline.impl

A Transformer-based implementation of a Processor.

TransformerProcessor(Transformer, ThreadingModel, PipeLink, PipeLink) - Constructor for class jconch.pipeline.impl.TransformerProcessor

Constructor.

U

UnboundedPipeLink<T> - Class in jconch.pipeline.impl

An unbounded link in the pipeline.

UnboundedPipeLink() - Constructor for class jconch.pipeline.impl.UnboundedPipeLink

Creates a new intance of UnboundedPipeLink.

V

values() - Method in class jconch.cache.CacheMap

Provides the values which have been generated at the moment.

A B C E F G H I J K L P R S T U V