//IO流(管道流)
import java.io.*;
//读取流
class Read implements Runnable
{
        private PipedInputStream in;
        Read(PipedInputStream in)
        {
                this.in = in;
        }
        public void run()
        {
                try
                {
                        byte[] buf = new byte[1024];

                        System.out.println("读取前。。没有数据阻塞");
                        int len = (in.read(buf));
                        System.out.println("读到数据。。阻塞结束");

                        String s = new String(buf,0,len);
                        System.out.println(s);
                        in.close();
                }
                catch (IOException e)
                {
                        throw new RuntimeException("管道读取流失败");
                }
        }
}
//输出流
class Write implements Runnable
{
        private PipedOutputStream out;
        Write(PipedOutputStream out)
        {
                this.out = out;
        }
        public void run()
        {
                try
                {
                        System.out.println("开始写入数据，等待...");
                        Thread.sleep(6000);
                        out.write("piped lai la".getBytes());
                        out.close();
                }
                catch (IOException e)
                {
                        throw new RuntimeException("管道输出流失败");
                }
        }
}
class  PipedStreamDemo
{
        public static void main(String[] args) throws IOException
        {
                PipedInputStream in = new PipedInputStream();
                PipedOutputStream out = new PipedOutputStream();
                in.connect(out);

                Read r = new Read(in);
                Write w = new Write(out);

                new Thread(r).start();
                new Thread(w).start();
        }
}
我编译的时候老是出现以下异常，而毕老师的没问题：
E:\java\day17>javac PipedStreamDemo.java
PipedStreamDemo.java:44: 错误: 未报告的异常错误InterruptedException; 必须对其进
行捕获或声明以便抛出
                        Thread.sleep(6000);
                                    ^
1 个错误

各位大神！请问是什么原因呢？怎么解决？

这就是因为Thread.sleep(6000);会抛出InterruptedException异常，而你并没有捕捉。这个异常需要trycatch处理

月光海 发表于 2014-6-2 18:00
这就是因为Thread.sleep(6000);会抛出InterruptedException异常，而你并没有捕捉。这个异常需要trycatch处 ...

恩！我刚才自己try了下，编译过了，为毛毕老师的没有抛出异常呢，这点有点费解

阿布Yocan 发表于 2014-6-2 18:14
恩！我刚才自己try了下，编译过了，为毛毕老师的没有抛出异常呢，这点有点费解 ...

没什么可费解的，毕老师用的Exception捕捉的，这个是所有异常的父类，所有的异常都可以捕捉

月光海 发表于 2014-6-2 18:17
没什么可费解的，毕老师用的Exception捕捉的，这个是所有异常的父类，所有的异常都可以捕捉 ...

好像毕老师也没有捕捉吧，我再去检查下，可能我漏掉了。谢谢你

sleep 需要处理异常