Tubi in IO fornisce un collegamento tra due thread in esecuzione contemporaneamente in JVM. Quindi i tubi vengono utilizzati sia come origine che come destinazione.
- PipedInputStream viene inoltre reindirizzato a PipedOutputStream. Pertanto i dati possono essere scritti utilizzando PipedOutputStream e possono essere scritti utilizzando PipedInputStream. Ma l'utilizzo di entrambi i thread contemporaneamente creerà un deadlock per i thread.
- Si dice che una pipe sia rotta se un thread che forniva byte di dati al flusso di output connesso tramite pipe non è più attivo.
Dichiarazione: public class PipedInputStream extends InputStream
Costruttore: | PipedInputStream() : | crea un PipedInputStream che non è connesso.
| PipedInputStream(int pSize): | crea un PipedInputStream che non è connesso alla dimensione della tubazione specificata.
| PipedInputStream(PipedOutputStream outStream): | crea un PipedInputStream connesso a PipedOutputStream - 'outStream'.
| PipedInputStream(PipedOutputStream outStream int pSize) : | crea un flusso di input convogliato connesso al flusso di output convogliato con la dimensione della tubazione specificata. Metodi: | int leggere(): | Reads the next byte of data from this piped input stream.The value byte is returned as an int in the range 0 to 255. This method blocks until input data is available the end of the stream is detected or an exception is thrown. Java // Java program illustrating the working of read() method import java.io.* ; public class NewClass { public static void main ( String [] args ) throws IOException { PipedInputStream geek_input = new PipedInputStream (); PipedOutputStream geek_output = new PipedOutputStream (); try { // Use of connect() : connecting geek_input with geek_output geek_input . connect ( geek_output ); // Use of read() method : geek_output . write ( 71 ); System . out . println ( 'using read() : ' + ( char ) geek_input . read ()); geek_output . write ( 69 ); System . out . println ( 'using read() : ' + ( char ) geek_input . read ()); geek_output . write ( 75 ); System . out . println ( 'using read() : ' + ( char ) geek_input . read ()); } catch ( IOException except ) { except . printStackTrace (); } } } Produzione : using read() : G using read() : E using read() : K
| read(byte[] buffer int offset int maxlen) : | java.io.PipedInputStream.read(byte[] buffer int offset int maxlen) legge fino a maxlen byte di dati dal flusso di input convogliato all'array di buffer. Il metodo si blocca se viene raggiunta la fine del flusso o se viene generata un'eccezione. Sintassi: public int read(byte[] buffer int offset int maxlen) Parameters : buffer : the destination buffer into which the data is to be read offset : starting in the destination array - 'buffer'. maxlen : maximum length of array to be read Return : next 'maxlen' bytes of the data as an integer value return -1 is end of stream is reached Exception : -> IOException : if in case IO error occurs. -> NullPointerException : if buffer is null. -> IndexOutOfBoundsException : if offset is -ve or maxlen is -ve or maxlen > buffer.length - offset.
| ricevere(int byte): | java.io.PipedInputStream.receive(int byte) riceve byte di dati. Se non è disponibile alcun input, il metodo si blocca. Sintassi: protected void receive(int byte) Parameters : byte : the bytes of the data received Return : void Exception : -> IOException : if in case IO error occurs or pipe is broken.
| vicino() : | java.io.PipedInputStream.close() chiude il flusso di input convogliato e rilascia le risorse allocate. Sintassi: public void close() Parameters : -------------- Return : void Exception : -> IOException : if in case IO error occurs.
| connect(origine PipedOutputStream): | java.io.PipedInputStream.connect(fonte PipedOutputStream) collega il flusso di input convogliato al flusso di output convogliato "sorgente" e nel caso in cui "sorgente" sia collegato a qualche altro flusso viene generata un'eccezione IO Sintassi: public void connect(PipedOutputStream source) Parameters : source : the Piped Output Stream to be connected to Return : void Exception : -> IOException : if in case IO error occurs.
| disponibile() : | java.io.PipedInputStream.available() restituisce n. di byte che possono essere letti da Input Stream senza essere effettivamente bloccati. Sintassi: public int available() Parameters : ------------- Return : no. of bytes that can be read from Input Stream without actually being blocked. 0 if the stream is already closed but by invoking close() method Exception : -> IOException : if in case IO error occurs.
Programma Java che spiega il funzionamento dei metodi della classe PipedInputStream: Java // Java program illustrating the working of PipedInputStream // connect() read(byte[] buffer int offset int maxlen) // close() available() import java.io.* ; public class NewClass { public static void main ( String [] args ) throws IOException { PipedInputStream geek_input = new PipedInputStream (); PipedOutputStream geek_output = new PipedOutputStream (); try { // Use of connect() : connecting geek_input with geek_output geek_input . connect ( geek_output ); geek_output . write ( 71 ); geek_output . write ( 69 ); geek_output . write ( 69 ); geek_output . write ( 75 ); geek_output . write ( 83 ); // Use of available() : System . out . println ( 'Use of available() : ' + geek_input . available ()); // Use of read(byte[] buffer int offset int maxlen) : byte [] buffer = new byte [ 5 ] ; // destination 'buffer' geek_input . read ( buffer 0 5 ); String str = new String ( buffer ); System . out . println ( 'Using read(buffer offset maxlen) : ' + str ); // USe of close() method : System . out . println ( 'Closing the stream' ); geek_input . close (); } catch ( IOException except ) { except . printStackTrace (); } } } Produzione: Use of available() : 5 Using read(buffer offset maxlen) : GEEKS Closing the stream
Next Article: Classe Java.io.PipedOutputStream in Java Crea quiz
Tubi in IO fornisce un collegamento tra due thread in esecuzione contemporaneamente in JVM. Quindi i tubi vengono utilizzati sia come origine che come destinazione. 
