A B C D F G I N O P S W

A

ActivationStack<E> - Class in org.semanticweb.elk.util.concurrent.collections

A thread-safe implementation of stack based on the non-blocking Treiber's Algorithm (Treiber, 1986).

ActivationStack() - Constructor for class org.semanticweb.elk.util.concurrent.collections.ActivationStack

AtomicIntegerFork - Class in org.semanticweb.elk.util.concurrent.sync

An AtomicInteger through which one can modify the AtomicInteger in an asynchronous way.

AtomicIntegerFork(AtomicInteger) - Constructor for class org.semanticweb.elk.util.concurrent.sync.AtomicIntegerFork

B

BaseInputProcessor<J> - Class in org.semanticweb.elk.util.concurrent.computation

FIXME delete it, the queue is not supposed to be local to the worker Implements basic job queueing and lets subclasses focus on processing single jobs

BaseInputProcessor() - Constructor for class org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor

BaseInputProcessor(InputProcessorListenerNotifyFinishedJob<J>) - Constructor for class org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor

C

ComputationExecutor - Class in org.semanticweb.elk.util.concurrent.computation

A custom ExecutorService for starting a several copies of runnable tasks, and waiting for it computation; it allows to interrupt all running tasks without shutting down the ExecutorService.

ComputationExecutor(int, ComputationThreadGroup) - Constructor for class org.semanticweb.elk.util.concurrent.computation.ComputationExecutor

Create a ComputationExecutor with a given maximal number of threads and the given thread group

ComputationExecutor(int, String) - Constructor for class org.semanticweb.elk.util.concurrent.computation.ComputationExecutor

Create a ComputationExecutor with a given maximal number of threads and the the given name which is used to identify threads

ComputationRuntimeException - Exception in org.semanticweb.elk.util.concurrent.computation

ComputationRuntimeException() - Constructor for exception org.semanticweb.elk.util.concurrent.computation.ComputationRuntimeException

ComputationRuntimeException(String) - Constructor for exception org.semanticweb.elk.util.concurrent.computation.ComputationRuntimeException

ComputationRuntimeException(String, Throwable) - Constructor for exception org.semanticweb.elk.util.concurrent.computation.ComputationRuntimeException

ComputationRuntimeException(Throwable) - Constructor for exception org.semanticweb.elk.util.concurrent.computation.ComputationRuntimeException

ComputationThreadGroup - Class in org.semanticweb.elk.util.concurrent.computation

Thread groups used by this executor

ComputationThreadGroup(String) - Constructor for class org.semanticweb.elk.util.concurrent.computation.ComputationThreadGroup

ConcurrentComputation<I,F extends InputProcessorFactory<I,?>> - Class in org.semanticweb.elk.util.concurrent.computation

An class for concurrent processing of a number of tasks.

ConcurrentComputation(F, ComputationExecutor, int, int) - Constructor for class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

Creating a ConcurrentComputation instance.

ConcurrentComputation(F, ComputationExecutor, int) - Constructor for class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

Creating a ConcurrentComputation instance.

D

DelegatingInputProcessor<J> - Class in org.semanticweb.elk.util.concurrent.computation

DelegatingInputProcessor(InputProcessor<J>) - Constructor for class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

F

finish() - Method in class org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor

finish() - Method in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

Marks the end of the input and requests all workers to terminate when all currently submitted input has been processed.

finish() - Method in class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

finish() - Method in interface org.semanticweb.elk.util.concurrent.computation.InputProcessor

Called when processing of the input is finished or interrupted.

finish() - Method in interface org.semanticweb.elk.util.concurrent.computation.InputProcessorFactory

a hook function to be called when all jobs are successfully processed

G

getEngine() - Method in interface org.semanticweb.elk.util.concurrent.computation.InputProcessorFactory

getInputProcessorFactory() - Method in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

getParent() - Method in class org.semanticweb.elk.util.concurrent.sync.AtomicIntegerFork

I

InputProcessor<J> - Interface in org.semanticweb.elk.util.concurrent.computation

An abstract interface for submitting and processing jobs of a certain type.

InputProcessorFactory<I,P extends InputProcessor<I>> - Interface in org.semanticweb.elk.util.concurrent.computation

An factory for creation of input processor engines of a given type.

InputProcessorListenerNotifyFinishedJob<J> - Interface in org.semanticweb.elk.util.concurrent.computation

A listener to be used with InputProcessor that can be used to perform actions when a job is processed.

interrupt() - Method in class org.semanticweb.elk.util.concurrent.computation.ComputationExecutor

Interrupting all threads of this executor (used to wake up waiting threads if something needs to be notified)

Interrupter - Interface in org.semanticweb.elk.util.concurrent.computation

An abstract interface for interrupting computations.

isInterrupted() - Method in class org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor

isInterrupted() - Method in interface org.semanticweb.elk.util.concurrent.computation.Interrupter

isInterrupted() - Method in class org.semanticweb.elk.util.concurrent.computation.SimpleInterrupter

N

notifyFinished(J) - Method in interface org.semanticweb.elk.util.concurrent.computation.InputProcessorListenerNotifyFinishedJob

This function is called after the input processor detects when the job is fully processed.

O

org.semanticweb.elk.util.concurrent.collections - package org.semanticweb.elk.util.concurrent.collections

org.semanticweb.elk.util.concurrent.computation - package org.semanticweb.elk.util.concurrent.computation

org.semanticweb.elk.util.concurrent.sync - package org.semanticweb.elk.util.concurrent.sync

P

peek() - Method in class org.semanticweb.elk.util.concurrent.collections.ActivationStack

pop() - Method in class org.semanticweb.elk.util.concurrent.collections.ActivationStack

Takes and removes the head element of the stack.

postProcess() - Method in class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

postSubmit(J) - Method in class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

preProcess() - Method in class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

preSubmit(J) - Method in class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

process() - Method in class org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor

process(J) - Method in class org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor

process() - Method in class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

process() - Method in interface org.semanticweb.elk.util.concurrent.computation.InputProcessor

Process all currently submitted jobs.

push(E) - Method in class org.semanticweb.elk.util.concurrent.collections.ActivationStack

Inserts the given element at the head of the stack.

S

setInterrupt(boolean) - Method in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

setInterrupt(boolean) - Method in interface org.semanticweb.elk.util.concurrent.computation.Interrupter

Set interrupt flag to the given value.

setInterrupt(boolean) - Method in class org.semanticweb.elk.util.concurrent.computation.SimpleInterrupter

SimpleInterrupter - Class in org.semanticweb.elk.util.concurrent.computation

A simple interrupter, which uses a flag about the interrupt status

SimpleInterrupter() - Constructor for class org.semanticweb.elk.util.concurrent.computation.SimpleInterrupter

start(Runnable, int) - Method in class org.semanticweb.elk.util.concurrent.computation.ComputationExecutor

Starts a several copies of jobs.

start() - Method in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

Starts the workers to process the input.

submit(J) - Method in class org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor

submit(I) - Method in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

Submitting a new input for processing.

submit(J) - Method in class org.semanticweb.elk.util.concurrent.computation.DelegatingInputProcessor

submit(J) - Method in interface org.semanticweb.elk.util.concurrent.computation.InputProcessor

Submit a job to be processed by this manager.

sync() - Method in class org.semanticweb.elk.util.concurrent.sync.AtomicIntegerFork

move the changes with this counter to the parent counter; the sums of the counters should be preserved if none of them is modified

W

waitDone() - Method in class org.semanticweb.elk.util.concurrent.computation.ComputationExecutor

Waits until all computations are done

waitWorkers() - Method in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

Wait until all currently running workers stop; no input can be submitted after calling this method.

A B C D F G I N O P S W