Package com.semedy.reasoner.api.core

Class ResultEnumeratorThreaded

java.lang.Object

com.semedy.reasoner.api.core.ResultEnumeratorThreaded

All Implemented Interfaces:

ResultEnumerator, Closeable, AutoCloseable, Cloneable

public class ResultEnumeratorThreaded
extends Object
implements Closeable, Cloneable, ResultEnumerator

enumerator for reasoning results

Author:

juergen

Constructor Summary

Constructors

Constructor	Description
ResultEnumeratorThreaded(BlockingQueue<Object> queue, int arity, List<String> variables, CoreReadLock readlock)	the producer

Method Summary

Modifier and Type	Method	Description
ResultEnumerator	cloneEnumerator()	clone the iterator
void	close()	close the iterator
ResultBufferThreaded	getBuffer()	get a result buffer
boolean	hasFinished()	Is the enumerator at the end?
boolean	hasMoreElements()	Are there more elements?
void	init()
void	nextElement()	Move to next element (the next element is found in the buffer)

Methods inherited from class java.lang.Object

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

Constructor Details

ResultEnumeratorThreaded

public ResultEnumeratorThreaded(BlockingQueue<Object> queue,
 int arity,
 List<String> variables,
 CoreReadLock readlock)

the producer

Method Details

init

public void init()

hasMoreElements

public boolean hasMoreElements()
                        throws IOException

Are there more elements?

Specified by:

hasMoreElements in interface ResultEnumerator

Returns:

true if there are more elements

Throws:

IOException

nextElement

public void nextElement()
                 throws IOException

Move to next element (the next element is found in the buffer)

Specified by:

nextElement in interface ResultEnumerator

Throws:

IOException

hasFinished

public boolean hasFinished()
                    throws IOException

Is the enumerator at the end?

Specified by:

hasFinished in interface ResultEnumerator

Returns:

true if there is no more result

Throws:

IOException

getBuffer

public ResultBufferThreaded getBuffer()

get a result buffer

Specified by:

getBuffer in interface ResultEnumerator

Returns:

buffer for results

close

public void close()
           throws IOException

close the iterator

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ResultEnumerator

Throws:

IOException

cloneEnumerator

public ResultEnumerator cloneEnumerator()
                                 throws IOException

clone the iterator

Specified by:

cloneEnumerator in interface ResultEnumerator

Returns:

Throws:

IOException