2019獨角獸企業重金招聘Python工程師標準>>>

1.管道輸入/輸出流類

? ? 分為兩類，字節流管道類（PipedInputStream/PipedOutputStream）和字符流管道類（PipedReader/?PipedWriter）。這兩個IO流實現了可以在不同的任務中對同一個管道進行讀寫操作，這個模型可以看成是“生產者消-費者模式”的變體，管道是一個阻塞隊列。

import java.io.IOException; import java.io.PipedInputStream; import java.io.PipedOutputStream; import java.io.PipedReader; import java.io.PipedWriter; import java.util.Scanner; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit;public class PipeIO {public static void main(String[] args) {ReadPipe read=new ReadPipe();WritePipe write=new WritePipe();ExecutorService exec=Executors.newCachedThreadPool();try {write.getWriter().connect(read.getRead());;//必須將兩個管道進行連接，然后才可進行線程間的數據交互exec.execute(read);exec.execute(write);} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}} } class ReadPipe implements Runnable{PipedReader read=new PipedReader();public PipedReader getRead(){return read;}@Overridepublic void run() {try {while(true){System.out.println("read:"+(char)read.read()+";");//當前線程從管道讀取數據} } catch (IOException e) {// TODO: handle exception}} } class WritePipe implements Runnable{PipedWriter writer=new PipedWriter();public PipedWriter getWriter(){return writer;}@Overridepublic void run() {try {while(true){for(char a='A';a<='z';a++){writer.write(a);//當前線程向管道輸出數據TimeUnit.SECONDS.sleep(2);}} } catch (IOException e) {// TODO: handle exception}catch (InterruptedException e) {// TODO: handle exception}} }

?

轉載于:https://my.oschina.net/ProgramerLife/blog/1806422

總結

以上是生活随笔為你收集整理的线程间的协作（3）——管道输入/输出流的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。