線程通信之管道流，線程通信管道

線程通信之管道流，線程通信管道

原文鏈接：http://www.bdqn.cn/news/201303/8270.shtml

管道流可以實現兩個線程之間，二進制數據的傳輸。

管道流就像一條管道，一端輸入數據，別一端則輸出數據。通常要分別用兩個不同的線程來控制它們。

使用方法如下：

1. import java.io.IOException;  

2. import java.io.PipedInputStream;  

3. import java.io.PipedOutputStream;  

4.  

5. public class PipedInputStreamTest {  

6.  

7.    public static void main(String[] args) {  

8.        //管道輸出流  

9.        PipedOutputStream out = new PipedOutputStream();  

10.        //管道輸入流  

11.        PipedInputStream in = null;  

12.        try {  

13.            //連接兩個管道流。或者調用connect(Piped..);方法也可以  

14.            in = new PipedInputStream(out);  

15.            Thread read = new Thread(new Read(in));  

16.            Thread write = new Thread(new Write(out));  

17.            //啟動線程  

18.            read.start();  

19.            write.start();  

20.        } catch (IOException e) {  

21.            e.printStackTrace();  

22.        }  

23.    }  

24. }  

25.  

26. class Write implements Runnable {  

27.    PipedOutputStream pos = null;  

28.  

29.    public Write(PipedOutputStream pos) {  

30.        this.pos = pos;  

31.    }  

32.  

33.    public void run() {  

34.        try {  

35.            System.out.println("程序將在3秒後寫入數據，請稍等。。。");  

36.            Thread.sleep(3000);  

37.            pos.write("wangzhihong".getBytes());  

38.            pos.flush();  

39.        } catch (IOException e) {  

40.            e.printStackTrace();  

41.        } catch (InterruptedException e) {  

42.            e.printStackTrace();  

43.        } finally {  

44.            try {  

45.                if (pos != null) {  

46.                    pos.close();  

47.                }  

48.            } catch (IOException e) {  

49.                e.printStackTrace();  

50.            }  

51.        }  

52.    }  

53. }  

54.  

55. class Read implements Runnable {  

56.    PipedInputStream pis = null;  

57.  

58.    public Read(PipedInputStream pis) {  

59.        this.pis = pis;  

60.    }  

61.  

62.    public void run() {  

63.        byte[] buf = new byte[1024];  

64.        try {  

65.            pis.read(buf);  

66.            System.out.println(new String(buf));  

67.        } catch (IOException e) {  

68.            e.printStackTrace();  

69.        } finally {  

70.            try {  

71.                if (pis != null) {  

72.                    pis.close();  

73.                }  

74.            } catch (IOException e) {  

75.                e.printStackTrace();  

76.            }  

77.        }  

78.    }  

79. }  

80.