org.semanticweb.elk.util.concurrent.computation

Class BaseInputProcessor<J>

java.lang.Object

org.semanticweb.elk.util.concurrent.computation.BaseInputProcessor<J>

All Implemented Interfaces:

InputProcessor<J>

public abstract class BaseInputProcessor<J>
extends Object
implements InputProcessor<J>

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

Author:

Pavel Klinov pavel.klinov@uni-ulm.de

Constructor Summary

Constructors

Constructor and Description
BaseInputProcessor()
BaseInputProcessor(InputProcessorListenerNotifyFinishedJob<J> listener)

Method Summary

Methods

Modifier and Type	Method and Description
void	finish() Called when processing of the input is finished or interrupted.
protected abstract boolean	isInterrupted()
void	process() Process all currently submitted jobs.
protected abstract void	process(J job)
void	submit(J job) Submit a job to be processed by this manager.

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseInputProcessor

public BaseInputProcessor()

BaseInputProcessor

public BaseInputProcessor(InputProcessorListenerNotifyFinishedJob<J> listener)

Method Detail

submit

public void submit(J job)

Description copied from interface: InputProcessor

Submit a job to be processed by this manager. This method can never fail or be interrupted.

Specified by:

submit in interface InputProcessor<J>

Parameters:

job - the job to be submitted

process

public void process()
             throws InterruptedException

Description copied from interface: InputProcessor

Process all currently submitted jobs. This method is intended to be executed from several threads, therefore it is not guaranteed that all jobs will be processed when the method terminates.

Specified by:

process in interface InputProcessor<J>

Throws:

InterruptedException - if interrupted during processing

finish

public void finish()

Description copied from interface: InputProcessor

Called when processing of the input is finished or interrupted. This method is eventually called after every call of InputProcessor.process() (but it is not guaranteed that every call of InputProcessor.process() is followed with InputProcessor.finish()).

Specified by:

finish in interface InputProcessor<J>

isInterrupted

protected abstract boolean isInterrupted()

process

protected abstract void process(J job)