com.hp.hpl.jena.graph.query
Class BufferPipe

java.lang.Object
  com.hp.hpl.jena.graph.query.BufferPipe

All Implemented Interfaces:

Pipe

public class BufferPipe

extends java.lang.Object

implements Pipe

This class is a pipe between query threads, implemented as a bounded buffer.

Author:

kers

Nested Class Summary

static class	BufferPipe.BoundedBufferPutException Exception to throw if a put throws an exception.
static class	BufferPipe.BoundedBufferTakeException Exception to throw if a take throws an exception.

Constructor Summary

BufferPipe()

Method Summary

void	close() Close the pipe: further operations on it have undefined effects.
Domain	get() Answer the next element if there is one, otherwise throw a NoSuchElementException.
boolean	hasNext() Answer true iff there are more elements for get() to get.
void	put(Domain d) Put a domain element into the pipe for later extraction.

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferPipe

public BufferPipe()

Method Detail

put

public void put(Domain d)

Description copied from interface: Pipe

Put a domain element into the pipe for later extraction.

Specified by:

put in interface Pipe

close

public void close()

Description copied from interface: Pipe

Close the pipe: further operations on it have undefined effects.

Specified by:

close in interface Pipe

hasNext

public boolean hasNext()

Description copied from interface: Pipe

Answer true iff there are more elements for get() to get.

Specified by:

hasNext in interface Pipe

get

public Domain get()

Description copied from interface: Pipe

Answer the next element if there is one, otherwise throw a NoSuchElementException.

Specified by:

get in interface Pipe