Weitere aktuelle Java-Titel finden Sie bei dpunkt.
 Inhaltsverzeichnis   Vorhergehendes Paket   Seite Zurück   Seite Vor   Nächstes Paket   Paketübersicht   Index

Klasse java.io.PipedInputStream1.0

java.lang.Object
   |
   +--java.io.InputStream
         |
         +--java.io.PipedInputStream

Deklaration

public class PipedInputStream
extends java.io.InputStream

Beschreibung

Mit den Klassen PipedInputStream und PipedOutputStream können zwei Threads Daten austauschen, indem Exemplare dieser Klassen verkettet werden. Die Verkettung erfolgt entweder mit dem Konstruktor oder der Methode connect(). Die read-Methoden des PipedInputStream liefern dann Daten, die von einem anderen Thread in den angeschlossenen PipedOutputStream geschrieben wurden.


 
Datenelemente
protected static final intPIPE_SIZE     [1.1]
protected byte[]buffer     [1.1]
protected intin     [1.1]
protected intout     [1.1]
 
Konstruktoren
publicPipedInputStream()
publicPipedInputStream(PipedOutputStream src)
 
Methoden
public synchronized intavailable()
public voidclose()
public voidconnect(PipedOutputStream src)
public synchronized intread()
public synchronized intread(byte[] b, int off, int len)
protected synchronized voidreceive(int b)     [1.1]


 

Datenelemente im Detail

protected static final int PIPE_SIZE     [1.1]
Voreingestellte Puffergröße.
protected byte[] buffer     [1.1]
FIFO-Puffer für die Daten. Die voreingestellte Größe beträgt 1024 Bytes.
protected int in     [1.1]
Zähler für die gelesenen Bytes.
protected int out     [1.1]
Zähler für die geschriebenen Bytes.

 

Konstruktoren im Detail

public PipedInputStream()
Erzeugt einen neuen PipedInputStream, der noch keine Verbindung besitzt. Vor der Benutzung muß er noch mit einem PipedOutputStream verbunden werden (entweder mit connect() oder dem Konstruktor von PipedOutputStream).
public PipedInputStream(PipedOutputStream src)
Erzeugt einen neuen PipedInputStream, der mit dem PipedOutputStream src verbunden ist.
Exception: IOException

 

Methoden im Detail

public synchronized int available()
Liefert die Anzahl an Bytes, die momentan gelesen werden kann, ohne zu blockieren.
Exception: IOException
public void close()
Schließt den Stream.
Exception: IOException
public void connect(PipedOutputStream src)
Verbindet den Stream mit src.
Exception: IOException
public synchronized int read()
Liest ein Byte aus dem Stream und liefert es zurück. Der Rückgabewert -1 signalisiert, dass das Ende des Streams erreicht wurde. Wenn momentan keine Daten im Stream bereitstehen, blockiert diese Methode so lange, bis wieder mindestens 1 Byte gelesen werden kann oder das Stream-Ende erreicht ist.
Exception: IOException
public synchronized int read(byte[] b, int off, int len)
Versucht, len Bytes aus dem Stream zu lesen und speichert sie ab dem Index off in b. Wenn beim Versuch, das erste Byte zu lesen, das Stream-Ende bereits erreicht war, ist der Rückgabewert -1, ansonsten wird die Anzahl der tatsächlich gelesenen Bytes zurückgeliefert. Wenn während des Lesevorgangs das Stream-Ende erreicht wird oder wenn im darunterliegenden Stream nur weniger als len Bytes gelesen werden können, ohne zu blockieren, kehrt die Methode zurück und liefert die Anzahl der bis dahin gelesenen Bytes.
Exception: IOException
protected synchronized void receive(int b)     [1.1]
Wird vom angeschlossenen PipedOutputStream aufgerufen, um Daten zu liefern.
Exception: IOException


 Inhaltsverzeichnis   Vorhergehendes Paket   Seite Zurück   Seite Vor   Nächstes Paket   Paketübersicht   Index

Copyright © 2002 dpunkt.Verlag, Heidelberg. Alle Rechte vorbehalten.