Java 中利用管道實現線程間的通訊

　　在Java 語言中，提供了各種各樣的輸入輸出流（stream）,使我們能夠很方便的對數據進行操作，其中，管道（pipe）流是一種非凡的流，用於在不同線程（threads）間直接傳送數據。一個線程發送數據到輸出管道，另一個線程從輸入管道中讀數據。通過使用管道，實現不同線程間的通訊。 <!-- frame contents --> <!-- /frame contents --> 無需求助於類似臨時文件之類的東西。本文在簡要介紹管道的基本概念後，將以一個具體的實例pipeapp加以具體說明。

　　1．管道的創建與使用
　　
　　Java提供了兩個非凡的專門的類專門用於處理管道，它們就是pipedinputstream類和pipeoutputstream類。
　　
　　Pipedinputstream代表了數據在管道中的輸出端，也就是線程向管道讀數據的一端；pipeoutputstream代表了數據在管道中的輸入端，也就是線程向管道寫數據的一端，這兩個類一起使用可以提供數據的管道流。
　　
　　為了創建一個管道流，我們必須首先創建一個pipeoutstream對象，然後，創建pipeinputstream對象，實例如下：
　　
　　pipeout= new pipedyoutstream();
　　pipein= new pipedputsteam(pipepout);
　　
　　一旦創建了一個管道後，就可以象操作文件一樣對管道進行數據的讀寫。

　　2．演示程序： pipeapp
　　
　　應用程序由三個程序組成：主線程（pipeapp.Java）及由主線程啟動的兩個二級線程（ythread.Java和zthread.Java）,它們使用管道來處理數據。程序從一個內容為一行一行"x"字母的"input.txt"文件中讀取數據，使用管道傳輸數據，第一次是利用線程ythread將數據"x"轉換為"y"，最後利用線程zthread將"y"轉換為"z",之後，程序在屏幕上顯示修改後的數據。
　　
　　主線程 （pipeapp.Java）
　　
　　在main()方法中，程序首先創建一個應用對象：pipeapp pipeapp=new pipeapp();
　　
　　由於程序中流操作都需要使用IOException異常處理，所以設置了一個try塊。在try中，為了從源文件中讀取數據，程序為"input.txt"文件創建了一個輸入流Xfileln,:
　　
　　fileinputstream xfileln= new fileinputstream("input.txt");
　　
　　新的輸入流傳遞給changetoy()方法，讓線程ythread能讀取該文件：
　　
　　inputstream ylnpipe =pipeapp.changetoy(xfileln);
　　
　　changetoy()方法創建將輸入數據"x"改變到"y"的線程ythread,並返回該線程的輸入管道：
　　
　　inputstream zlnpipe = pipeapp.changetoz(ylnpipe);
　　
　　changetoz()方法啟動將數據從"y"改變到"z"的線程zehread,主程序將使用從changetoz()返回的輸入管道。得到以修改的數據。
　　
　　然後，程序將管道輸入流定位到datainputstream對象，使程序能夠使用readline()方法讀取數據：
　　datainputstream inputstream = new datainputstream(zlnpiepe);
　　
　　創建了輸入流以後，程序就可以以行一行的讀取數據病顯示在屏幕上。
　　

　　String str= inputstream.readline();
　　While(str!=null)
　　{
　　system.out.println(str);
　　str=inputstream.readline();
　　}

　　顯示完成之後，程序關閉輸入流：
　　

　　inputstream.close();
　　changetoy()方法

　　changetoy()方法首先通過傳遞一個參數inputstream給datainputstream對象來定位資源的輸入流，使程序能使用readline()方法從流中讀取數據：
　　
　　datainputstream xfileln =new datainutstream(inputstream)；
　　
　　然後，changetoy()創建輸出管道和輸入管道：
　　

　　pipeoutstream pipeout = new pipeoutputstream();
　　pipeinputstream pipeln = new pipedinputsteam(pipeout);

　　為了能夠使用println()方法輸出修改的後的文本行到管道，程序將輸出管道定位到printstream對象：
　　
　　printstream printstream = new printstream(pipeout);
　　
　　現在，程序可以創建將數據從x改變到y的線程，該線程是ythread類的一個對象，他傳遞兩個參數：輸入文件（xfileln）和輸出管道（調用printstream）
　　
　　ythread ythread =new thread(xfileln,printstream);
　　
　　之後，程序啟動線程：
　　
　　changetoz（）方法
　　
　　changetoz()方法與changetoy()方法很相似，他從changetoy()返回的輸入流開始：