A B C D E F G I M N O P R 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

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

buffer - Variable in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

the internal buffer for queuing input

C

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

Clears the interrupt status: computation is no longer interrupted

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

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

De-registers a thread to be interrupted (so that no thread is interrupted accidently)

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

E

executor - Variable in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

the executor used internally to run the jobs

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

Indicate that processing of the input is finished.

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

a hook function to be called when all jobs are processed

finishRequested - Variable in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

true if the finish of computation was requested using the function ConcurrentComputation.finish()

G

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

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 - Variable in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

the factory for the input processor engines

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)

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

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

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

Requests the computation to be interrupted

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

interrupted - Variable in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

true if the computation has been interrupted

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

An abstract interface for interrupting computations and monitoring if computations have been interrupted.

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

Checks if the computation was requested to be interrupted

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

M

maxWorkers - Variable in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

maximum number of concurrent workers

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.

R

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

Assign the current thread is interrupted when SimpleInterrupter.interrupt() is called

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

Make sure the given thread is interrupted when SimpleInterrupter.interrupt() is called

S

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

A simple interrupter, which just stores the flag about the interrupt status and interrupts the thread that is assigned to this interrupter

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

worker - Variable in class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

the worker instance used to process the jobs

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