在 Java 中，BufferedReader.lines().forEach() 是阻塞式操作，会一直等待流结束或新数据到达，导致程序无法继续执行后续逻辑；解决该问题的核心方案是采用多线程（如 ExecutorService）并发处理各输入流，避免主线程被单个流阻塞。
在 java 中，`bufferedreader.lines().foreach()` 是阻塞式操作，会一直等待流结束或新数据到达，导致程序无法继续执行后续逻辑；解决该问题的核心方案是采用多线程（如 `executorservice`）并发处理各输入流，避免主线程被单个流阻塞。
BufferedReader.lines() 返回的是一个惰性求值的 Stream
✅ 正确做法：为每个 InputStream 分配独立线程，使用非阻塞或带超时机制的读取方式。推荐使用 ExecutorService 管理线程，并配合 BufferedReader.readLine() 循环读取（而非 lines().forEach()），以实现真正的“边读边做其他事”。
以下是改进后的完整示例：
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ConcurrentInputStreamReader {
private static final ExecutorService executor = Executors.newCachedThreadPool();
public static void main(String[] args) {
// 假设 cmdsin 和 datain 是已打开的 InputStream（例如 Process.getInputStream()）
InputStream cmdsin = ...; // e.g., process.getInputStream()
InputStream datain = ...; // e.g., another socket or pipe input
// 启动线程分别监听两个流
executor.submit(() -> readStream(cmdsin, "CMD"));
executor.submit(() -> readStream(datain, "DATA"));
// 主线程可自由执行其他逻辑（定时任务、状态检查、用户交互等）
while (!Thread.currentThread().isInterrupted()) {
System.out.println("Main thread is running other tasks...");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
}
}
executor.shutdown();
}
private static void readStream(InputStream in, String prefix) {
try (BufferedReader reader = new BufferedReader(
new InputStreamReader(in, StandardCharsets.UTF_8))) {
String line;
while ((line = reader.readLine()) != null) {
System.out.println(prefix + ": " + line);
}
} catch (IOException e) {
System.err.println(prefix + " stream closed or error: " + e.getMessage());
}
}
}
? 关键要点说明：
- ✅ readLine() 是逐行非批量阻塞调用，每次只等待一行，便于响应中断或配合超时控制；
- ✅ 使用 ExecutorService 统一管理线程生命周期，避免资源泄漏；
- ⚠️ 注意：InputStream 本身不支持原生超时，若需防止某流长期无响应，可包装为 java.nio.channels.Channels.newChannel(in) 并结合 Selector（适用于 ReadableByteChannel），但对普通 Process 或 Socket 输入流，更实用的方式是确保源头（如子进程）能正常关闭流；
- ⚠️ 不要重复创建 InputStreamReader/BufferedReader（如原代码中循环内新建），这不仅低效，还可能因流已被消费而丢失数据。
总结：Java 中并发读取多个 InputStream 的标准解法是「一线一程 + readLine() 循环」，而非试图在单线程中用函数式流 API 实现“伪并发”。多线程不是“权宜之计”，而是 I/O 并发的合理且必要设计模式。
