Java InputStream 在线程中关闭

Question

我正在尝试从线程中的输入流读取。

线程应该运行的类如下所示

static private class Runner implements Runnable {

    private InputStream fis;
    private OutputStream fos;

    public Runner(InputStream fis, OutputStream fos) throws IOException {

        int blu = fis.available();

        System.out.println(blu);

        this.fis = fis;

        int bla = this.fis.available();

        System.out.println(bla);
        this.fos = fos;
    }

    @Override
    public void run() {

        try {
            int bla = fis.available();

            System.out.println(bla);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println(fis);
        System.out.println(fos);

    }

}

线程是这样创建的

final Runnable runnable = new Runner(fis, fos);
final Thread thread = new Thread(runnable);
thread.start();

并且在线程上应该运行 run 方法。但是一旦执行我就会收到错误

java.nio.channels.ClosedChannelException

我调试了它并且InputStream设置为关闭。

为什么输入流在线程中被关闭？我应该使用其他替代方案吗？

编辑：

我忘了提到它们是在这样的 try 块中打开的，之后 main 函数就结束了。

try (InputStream fis = Files.newInputStream(sourcePath)) {
        try (OutputStream fos = Files.newOutputStream(sinkPath)) {

            final Runnable runnable = new Runner(fis, fos);
            final Thread thread = new Thread(runnable);
            thread.start();
        }

    }

Answer 1

当块退出时，这些try-with-resources块将关闭它们各自的流。当您只计划使用块内的流时，这非常有用。但是，由于您希望在块结束后继续在另一个线程中使用流，因此请摆脱块。

InputStream  fis = Files.newInputStream (sourcePath);
OutputStream fos = Files.newOutputStream(sinkPath);

final Runnable runnable = new Runner(fis, fos);
final Thread   thread   = new Thread(runnable);
thread.start();