如何同时读取多个输入流并执行其他任务

本文讨论的是Ja va中一个很实际的问题：如何并发读取多个InputStream（比如命令输出流和数据流），避免单线程阻塞导致程序卡死或后续逻辑无法执行。核心思路是为每个输入流分配独立线程，配合BufferedReader.lines()的惰性流特性，再加上合理的资源管理。

在Ja va开发中，同时读取多个输入流（例如外部进程的输出流、数据流）是一个常见场景，但单线程顺序处理往往就栽在一个看似不起眼的坑里：BufferedReader.lines()返回的是一个惰性求值的Stream，它会一直等待新行输入，直到源流关闭或抛出异常。换句话说，如果你用br.lines().forEach(...)串行处理多个阻塞流，第一个流没读完、没关闭，后面的代码就永远跑不到——这正是那句“this never runs”永不执行的根本原因。单线程一条路走到黑，肯定不行，必须引入并发机制。

✅ 正确的做法：为每个输入流启动独立的守护线程，实现非阻塞、并行读取。下面是一段典型的实现：

// 启动线程1：监听 cmdsin
Thread cmdThread = new Thread(() -> {
    try (InputStreamReader isr = new InputStreamReader(cmdsin, StandardCharsets.UTF_8);
         BufferedReader br = new BufferedReader(isr)) {
        br.lines().forEach(line -> System.out.println("CMD: " + line));
    } catch (IOException e) {
        System.err.println("CMD stream error: " + e.getMessage());
    }
}, "CmdReader");
cmdThread.setDaemon(true); // 避免JVM因该线程挂起
cmdThread.start();

// 启动线程2：监听 datain
Thread dataThread = new Thread(() -> {
    try (InputStreamReader isr2 = new InputStreamReader(datain, StandardCharsets.UTF_8);
         BufferedReader br2 = new BufferedReader(isr2)) {
        br2.lines().forEach(line -> System.out.println("DATA: " + line));
    } catch (IOException e) {
        System.err.println("DATA stream error: " + e.getMessage());
    }
}, "DataReader");
dataThread.setDaemon(true);
dataThread.start();

// 主线程可自由执行其他逻辑（如定时任务、状态检查、用户交互等）
while (!Thread.interrupted()) {
    System.out.println("Main thread is running... (e.g., health check, config reload)");
    Thread.sleep(2000);
}

⚠️ 关键的几个注意事项：

• 务必使用 try-with-resources：这样才能确保 InputStreamReader 和 BufferedReader 在流结束或异常时自动关闭，防止资源泄漏。
• 设置为守护线程（setDaemon(true)）：让子线程不阻止JVM退出；如果你需要保证流处理完成再退出，那就改用 join() 来协调生命周期。
• 避免在 forEach 中执行耗时操作：lines().forEach(...) 内部仍然是同步调用。如果追求高吞吐，可以考虑改用 lines().parallel().forEach(...)（注意线程安全问题），或者用 lines().forEachOrdered(...) 保持顺序。
• 流关闭时机决定读取何时终止：lines() 只有在底层 readLine() 返回 null（即流关闭）时才结束。如果上游程序没显式关闭流（比如进程没退出），线程就会一直等下去——这时候就需要配合超时机制或外部信号来中断。

? 进阶建议：如果遇上更复杂的 I/O 调度场景（比如动态增删流、背压控制），可以考虑 NIO.2 的 AsynchronousFileChannel 或者反应式库（像 Project Reactor 的 Flux.fromInputStream）。但对于标准 Process.getInputStream() 这类阻塞流，多线程方案依然是最简洁可靠的选择。