BufferPipe

Overview

Package

Class

Use

Deprecated

Index

Home >> All >> com >> hp >> hpl >> jena >> graph >> [ query overview ]

PREV CLASS NEXT CLASS

SUMMARY:

DETAIL: FIELD | CONSTR | METHOD

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

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

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

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.

static class BufferPipe.Finished


Field Summary

private EDU.oswego.cs.dl.util.concurrent.BoundedBuffer buffer


private static BufferPipe.Finished finished


private boolean open


private java.lang.Object pending


Constructor Summary

BufferPipe()


Method Summary

void close()
          Close the pipe.

void close(java.lang.Exception e)
          Close the pipe (see close()) and record e as its termination status.

private java.lang.Object fetch()
          put something into the pipe; take care of BoundedBuffer's checked exceptions

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.

private void putAny(java.lang.Object d)
          get something from the pipe; take care of BoundedBuffer's checked exceptions

Methods inherited from class java.lang.Object

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

Field Detail

private boolean open

private EDU.oswego.cs.dl.util.concurrent.BoundedBuffer buffer

private java.lang.Object pending

private static final BufferPipe.Finished finished

Constructor Detail

public BufferPipe()

Method Detail

private java.lang.Object fetch()

put something into the pipe; take care of BoundedBuffer's checked exceptions

private void putAny(java.lang.Object d)

get something from the pipe; take care of BoundedBuffer's checked exceptions