Java中BufferedReader本身是阻塞式IO，但可通过CompletableFuture提交到线程池实现逻辑异步读取；支持单行异步获取、全行异步收集为List、流式逐行异步处理三种模式，需注意线程安全、资源关闭及时性及超时控制。
Java 中 BufferedReader 本身是阻塞式 IO，不能直接异步，但可以借助 CompletableFuture 将其读取操作提交到线程池执行，实现“逻辑上的异步按行读取”。关键不是让 BufferedReader 变成非阻塞，而是避免主线程被阻塞。
用 CompletableFuture 包装单次 readLine() 调用
适用于需要异步读取**某一行**（比如首行、特定行）的场景。把 readLine() 放进独立线程执行，返回 CompletableFuture<string></string>：
- 创建线程池（推荐使用
ForkJoinPool.commonPool()或自定义ThreadPoolExecutor） - 用
CompletableFuture.supplyAsync(() -> reader.readLine(), executor)提交任务 - 注意：
reader.readLine()仍会阻塞该线程，但不会阻塞调用方线程
异步读取全部行并收集为 List
适合文件不大、需一次性获取所有行的场景。封装一个返回 CompletableFuture<List<String>> 的方法：
- 在异步任务中循环调用
readLine()，直到返回null - 建议使用
ArrayList动态添加，避免频繁扩容影响性能 - 务必在 finally 块中关闭
BufferedReader（或用 try-with-resources + 异步捕获异常） - 示例：
CompletableFuture<List<String>> lines = CompletableFuture.supplyAsync(() -> { try (var r = reader) { ... } });
流式异步逐行处理（推荐用于大文件）
避免一次性加载全部内容到内存，用 CompletableFuture 驱动逐行消费（类似反应式风格）：
立即学习“Java免费学习笔记（深入）”；
- 不返回完整列表，而是对每一行执行异步处理（如写入数据库、发 HTTP 请求）
- 可用递归式
thenCompose实现链式读取：读一行 → 处理 → 再读下一行 - 注意栈溢出风险，大文件建议改用循环 +
CompletableFuture.runAsync控制流程 - 每行处理可独立失败，需合理设计错误传播（如
exceptionally或handle）
注意事项和常见坑
实际使用时容易忽略的关键点：
-
BufferedReader 不是线程安全的：同一个实例不能被多个 CompletableFuture 同时调用
readLine() - 关闭资源时机很重要：若在异步任务外提前 close，会导致
IOException - 不要在 Lambda 中直接捕获并重用
BufferedReader实例，尤其涉及多次异步调用时 - 如果底层是网络流（如 Socket），超时控制需额外处理，
BufferedReader本身不支持设置超时
