黑马程序员技术交流社区

标题: 关于管道流实现线程间通信的问题 [打印本页]
作者: 柳彬    时间: 2012-9-12 09:45
标题: 关于管道流实现线程间通信的问题
本帖最后由 柳彬 于 2012-9-24 08:02 编辑

关于管道流实现线程间通信的问题，大家帮忙举个具有实战的例子。要有源代码哦。
作者: 王金科    时间: 2012-9-12 20:45
  1. package cn.study.io;


  4. import java.io.IOException;
  5. import java.io.PipedInputStream;
  6. import java.io.PipedOutputStream;

  8. public class PipedStreamDemo {

  10.         /**
  11.          * @param args
  12.          * @throws IOException
  13.          */
  14.         public static void main(String[] args) throws IOException {
  15.                 // TODO Auto-generated method stub

  17.                 final PipedInputStream pis = new PipedInputStream();
  18.                 final PipedOutputStream pos = new PipedOutputStream();
  19.                
  20.                 Thread read = new Thread(){
  21.                         public void run(){
  22.                                 try {
  23.                                         byte[] buf = new byte[1024];
  24.                                         System.out.println("读取前,没有数据,等待...");
  25.                                         int len = pis.read(buf);
  26.                                         System.out.println("读到数据,打印数据...");
  27.                                         String str = new String(buf,0,len);
  28.                                         System.out.println(str);
  29.                                         pis.close();
  30.                                 } catch (IOException e) {
  31.                                         // TODO Auto-generated catch block
  32.                                         e.printStackTrace();
  33.                                 }
  34.                         }
  35.                 };
  36.                
  37.                 Runnable write = new Runnable(){
  38.                         public void run(){
  39.                                 try {
  40.                                         System.out.println("开始写入数据,等待6秒后...");
  41.                                         Thread.sleep(6000);
  42.                                         pos.write("piped lai la".getBytes());
  43.                                         pos.close();
  44.                                 } catch (Exception e) {
  45.                                         // TODO Auto-generated catch block
  46.                                         e.printStackTrace();
  47.                                 }
  48.                         }
  49.                 };
  50.                 pis.connect(pos);
  51.                 read.start();
  52.                 new Thread(write).start();               
  53.         }
  54. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2