Package chemaxon.util.concurrent.marvin

Class MolInputProducer

java.lang.Object

chemaxon.util.concurrent.marvin.MolInputProducer

All Implemented Interfaces:

chemaxon.util.concurrent.InputProducer<Molecule>, chemaxon.util.concurrent.util.ConcurrentIterator<Molecule>

@PublicApi
public class MolInputProducer
extends Object
implements chemaxon.util.concurrent.InputProducer<Molecule>

Input producer wrapping a MolImporter object. Produces Molecule objects for the concurrent plugin examples.

Since:

Marvin 5.0

Constructor Summary

Constructors

Constructor	Description
MolInputProducer()	Constructor.
MolInputProducer(MolImporter importer)	Constructor.
MolInputProducer(MolImporter[] importers)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the importers.
Molecule	getNext()	Returns the next input molecule.
boolean	hasNext()	Returns true if there are more molecules, false if end has been reached.
protected Molecule	read(MolImporter importer)

Methods inherited from class java.lang.Object

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

Constructor Details

MolInputProducer

public MolInputProducer()
                 throws ExecutionException

Constructor. Creates a molecule importer which will read the standard input.

Throws:

ExecutionException

MolInputProducer

public MolInputProducer(MolImporter importer)

Constructor. Sets a single molecule importer.

Parameters:

importer - the molecule importer object

MolInputProducer

public MolInputProducer(MolImporter[] importers)

Constructor. Sets the molecule importers.

Parameters:

importers - the molecule importer objects

Method Details

hasNext

public boolean hasNext()
                throws InterruptedException,
ExecutionException

Returns true if there are more molecules, false if end has been reached.

Specified by:

hasNext in interface chemaxon.util.concurrent.util.ConcurrentIterator<Molecule>

Returns:

true if there are more molecules

Throws:

InterruptedException

ExecutionException

getNext

public Molecule getNext()
                 throws InterruptedException,
ExecutionException

Returns the next input molecule.

Specified by:

getNext in interface chemaxon.util.concurrent.util.ConcurrentIterator<Molecule>

Returns:

the next input molecule

Throws:

InterruptedException

ExecutionException

read

protected Molecule read(MolImporter importer)
                 throws IOException

Throws:

IOException

close

public void close()
           throws ExecutionException

Closes the importers.

Throws:

ExecutionException