org.semanticweb.elk.util.concurrent.computation

Interface InputProcessor<J>

Type Parameters:

J - the type of the jobs to be submitted and processed

All Known Implementing Classes:

BaseInputProcessor, DelegatingInputProcessor

public interface InputProcessor<J>

An abstract interface for submitting and processing jobs of a certain type. It has a method for submitting jobs and processing of the submitted jobs, which are typically executed from concurrently running workers.

Author:

"Yevgeny Kazakov"

Method Summary

Methods

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

Method Detail

submit

void submit(J job)

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

Parameters:

job - the job to be submitted

process

void process()
             throws InterruptedException

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.

Throws:

InterruptedException - if interrupted during processing

finish

void finish()

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