The Clasa PipedWriter în Java permite două fire să comunice între ele prin trecerea datelor printr-o conductă. Această clasă este utilă atunci când dorim ca o parte a programului să trimită date către o altă parte fără a le stoca în memorie.

Caracteristici ale clasei PipedWriter:

• Permite scrierea datelor într-o conductă.
• Utilizează un buffer pentru a stoca temporar datele înainte de a le trimite către PipedReader.
• Funcționează cu PipedReader pentru a asigura transferul sigur de date între fire.
• Daca teava se rupe, se produce o eroare.

Declarația PipedWriter în Java

Declarația clasei PipedWriter este:

clasa publică PipedWriter extinde Writer

Toate interfețele implementate:

• Închidere: Această interfață este folosită de clasele care gestionează resurse.
• Flushable: Această interfață este utilizată pentru a șterge datele la destinație.
• Anexabil: Această interfață este utilizată pentru a adăuga date la un flux existent.
• Închidere automată: Această interfață permite închiderea automată a resurselor.

Constructori din clasa PipedWriter

Această clasă este formată din doi constructori cu ajutorul cărora putem crea obiecte din această clasă în moduri diferite. Următorii sunt constructorii disponibili în această clasă:

1. PipedWriter(): Acest constructor este folosit pentru a crea un PipedWriter care nu este încă conectat la nimic.

Sintaxă:

PipedWriter()

Exemplu:

// Demonstrating the working // of PipedWriter() import java.io.*; class Geeks {  public static void main(String[] args) {    // Create PipedWriter and PipedReader  PipedWriter w = new PipedWriter();  PipedReader r = new PipedReader();  try {  // Connect the PipedWriter to the PipedReader  w.connect(r);  // Create a thread to write data into the pipe  Thread writerThread = new Thread(new Runnable() {  public void run() {  try {  w.write('Hello from PipedWriter!');  w.close();  } catch (IOException e) {  e.printStackTrace();  }  }  });  // Create a thread to read data from the pipe  Thread readerThread = new Thread(new Runnable() {  public void run() {  try {  int data;  while ((data = r.read()) != -1) {  System.out.print((char) data);  }  r.close();  } catch (IOException e) {  e.printStackTrace();  }  }  });  // Start both threads  writerThread.start();  readerThread.start();  // Wait for both threads to finish  writerThread.join();  readerThread.join();  } catch (IOException | InterruptedException e) {  e.printStackTrace();  }  } } 

Hello from PipedWriter!

2. PipedWriter (PipedReader inStream): Acest constructor folosit pentru a crea un PipedWriter și îl conectează la un PipedReader.

python scrie json în fișier

Sintaxă:

PipedWriter (snk PipedReader)

Exemplu:

// Demonstrating the working  // PipedWriter(PipedReader snk) import java.io.*; public class Geeks {  public static void main(String[] args) {  try {  // Create a PipedReader and a PipedWriter  PipedReader r = new PipedReader();  PipedWriter w = new PipedWriter(r);   // Create a thread to write data to the PipedWriter  Thread writerThread = new Thread(() -> {  try {  w.write('Hello PipedWriter');  w.close();   } catch (IOException e) {  e.printStackTrace();  }  });  // Create a thread to read data from the PipedReader  Thread readerThread = new Thread(() -> {  try {  int data;  while ((data = r.read()) != -1) {  System.out.print((char) data);   }  } catch (IOException e) {  e.printStackTrace();  }  });  // Start both threads  writerThread.start();  readerThread.start();  // Wait for both threads to finish  writerThread.join();  readerThread.join();  } catch (IOException | InterruptedException e) {  e.printStackTrace();  }  } } 

Hello PipedWriter

Metode Java PipedWriter

Imaginea de mai jos demonstrează metodele clasei PipedWriter.

Acum vom discuta despre fiecare metodă una câte una în detaliu:

1. scrie (int char): Această metodă este folosită pentru a scrie un singur caracter într-un pipe.

Sintaxă:

public void write(int char)

• Parametru: Această metodă ia un parametru care reprezintă caracterul care urmează să fie scris.
• Excepţie: Această metodă returnează IOException dacă există o problemă cu operația I/O.

2. scrie(char[] carray int offset int maxlen): Această metodă este folosită pentru a scrie caractere dintr-o matrice în conductă.

Sintaxă:

public void write(char[] carray int offset int maxlen)

• Parametru: Această metodă include trei parametri care sunt enumerați mai jos:
  • carray: Este matricea de caractere care conține date
  • compensare: Este poziția din matrice de unde să începeți să scrieți formularul
  • maxlen: Este numărul maxim de caractere de scris.
• Excepţie: Această metodă returnează IOException dacă există o problemă cu operația I/O.

3. conectați (destinație PipedReader): Această metodă este folosită pentru a conecta PipedWriter la un PipedReader.

Sintaxă:

public void connect (destinație PipedReader)

• Parametru: Această metodă ia o destinație de parametru, acesta este PipedReader la care PipedWriter se va conecta pentru transferul de date.
• Excepţie: Această metodă aruncă IOException dacă apare o eroare în timpul conectării.

4. spălare(): Această metodă este utilizată pentru a spăla datele din conductă.

Sintaxă:

spălare public void()

• Parametru: Această metodă nu ia niciun parametru.
• Excepţie: Această metodă aruncă IOException dacă apare o eroare în timpul spălării datelor.

5. închide(): Această metodă este folosită pentru a închide PipedWriter.

Synatx:

vid public close()

• Parametru: Această metodă nu ia niciun parametru.
• Excepţie: Această metodă aruncă IOException dacă există o problemă cu închiderea scriitorului.

Acum vom discuta cum putem folosi clasa PipedWriter pentru a scrie date și a le citi printr-un PipedReader conectat

Exemplu:

// Demonstrating how to use PipedReader  // and PipedWriter to transferr an array  // of characters between two threads import java.io.*;  public class Geeks {   public static void main(String[] args) throws IOException {   PipedReader r = new PipedReader();   PipedWriter w = new PipedWriter();   r.connect(w); // Must connect before use   // Writing a char array   char[] c = {'J' 'A' 'V' 'A'};   w.write(c 0 4);   // Reading blocks if no data is written yet  System.out.print('Output from the pipe:');   for (int i = 0; i < 4; i++) {   System.out.print(' ' + (char) r.read());   }   w.close();   r.close();   }  } 

Output from the pipe: J A V A

Program Java care ilustrează funcționarea metodelor clasei PipedWriter

Acum vom scrie câteva caractere care vor șterge rezultatul și vom închide scriitorul.

șir invers java

Exemplu:

// Java program illustrating the working of PipedWriter  // write() connect  // close() flush() import java.io.*; public class Geeks {    public static void main(String[] args) throws IOException {  PipedReader r = new PipedReader();  PipedWriter w = new PipedWriter();  try {  // Use of connect(): Connecting the writer to the reader  r.connect(w);  // Use of write(int byte): Writing characters to the pipe  w.write(71);   w.write(69);  w.write(69);  w.write(75);  w.write(83);   // Use of flush() method: Flushing the output to   // make sure all data is written  w.flush();  System.out.println('Output after flush():');  // Reading from the pipe  for (int i = 0; i < 5; i++) {  System.out.print(' ' + (char) r.read());  }  // Use of close() method: Closing the writer  System.out.println('nClosing the Writer stream');  w.close();  } catch (IOException e) {  e.printStackTrace();  }  } } 

Output after flush(): G E E K S Closing the Writer stream