使用多线程实现Keyboard Listener时遇问题，附Java代码片段

我来帮你拆解下这段多线程实现键盘监听代码里可能踩的坑，以及对应的解决办法：

1. 线程安全：out变量的可见性隐患 #

你定义的out是普通静态布尔变量，在多线程环境下，一个线程修改它的值后，另一个线程可能无法立刻看到更新（因为CPU缓存的存在），这会导致监听线程一直无法感知键盘输入事件。

解决办法：

• 把out声明为volatile，强制线程每次读取都从主内存获取最新值：private static volatile boolean out=false;
• 更推荐用Java并发包的原子类，比如AtomicBoolean，它自带线程安全的读写操作：private static AtomicBoolean out = new AtomicBoolean(false);

2. 资源泄漏：IO流未正确关闭 #

你的代码里reader.close()放在try块里，如果readLine()抛出异常，流就不会被关闭，会造成资源泄漏。

解决办法：
用Java的try-with-resources语法，它会自动关闭实现了AutoCloseable接口的资源：

try (BufferedReader reader = new BufferedReader(new InputStreamReader(System.in))) {
    reader.readLine();
} catch (IOException e) {
    System.err.println("键盘输入异常：" + e.getMessage());
    e.printStackTrace();
}

3. 低效的线程等待（假设第二个线程是监听out的） #

如果你的第二个线程是循环检查out的值来判断是否有键盘输入，这种“忙等”会持续占用CPU资源，非常低效。

解决办法：
用并发工具类替代忙等，比如CountDownLatch或者Condition：

• 用CountDownLatch：初始化时设置计数为1，输入线程完成后调用countDown()，监听线程调用await()等待，这样线程会进入休眠，直到被唤醒，完全不占用CPU。

4. 主线程提前退出导致程序终止 #

如果主线程启动两个子线程后没有等待它们完成，主线程会直接结束，整个JVM进程也会跟着终止，子线程可能还没执行完就被强制关闭。

解决办法：
在主线程里调用子线程的join()方法，等待子线程执行完毕：

Thread inputThread = new Thread(...);
Thread listenerThread = new Thread(...);
inputThread.start();
listenerThread.start();

// 等待两个子线程完成
inputThread.join();
listenerThread.join();

优化后的完整示例代码 #

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.concurrent.CountDownLatch;

public class KeyboardListener {
    private static final CountDownLatch inputLatch = new CountDownLatch(1);

    public static void main(String[] args) {
        // 键盘输入线程
        Thread inputThread = new Thread(() -> {
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(System.in))) {
                System.out.println("请输入任意内容后回车：");
                reader.readLine();
                System.out.println("已接收到键盘输入");
                inputLatch.countDown(); // 通知监听线程
            } catch (IOException e) {
                System.err.println("键盘输入出错：" + e.getMessage());
                e.printStackTrace();
            }
        });

        // 逻辑监听线程
        Thread listenerThread = new Thread(() -> {
            try {
                inputLatch.await(); // 等待键盘输入完成
                System.out.println("监听线程：开始执行输入后的逻辑");
                // 这里写你需要执行的后续业务代码
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt(); // 恢复中断标记
                System.err.println("监听线程被中断：" + e.getMessage());
            }
        });

        inputThread.start();
        listenerThread.start();

        try {
            // 主线程等待子线程完成
            inputThread.join();
            listenerThread.join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            e.printStackTrace();
        }
    }
}

额外提醒 #

如果你的需求是全局键盘监听（不是控制台输入），那这段代码的思路不适用——BufferedReader只能读取控制台的输入。这种情况下需要使用系统级的API或者第三方库，比如：

• 用java.awt.Robot配合事件监听（仅适用于AWT/Swing程序）
• 第三方库JNativeHook，支持跨平台的全局键盘监听

内容的提问来源于stack exchange，提问作者yiii_tian