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

java.lang.Object
  extended bycom.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


Copyright © 2000-2003 Hewlett-Packard. All Rights Reserved.