切换JavaFX ChoiceBox时后台线程未中断引发应用崩溃

我来帮你搞定这个问题——你遇到的崩溃十有八九是因为切换音频接口时，旧的线程和音频资源没被正确清理干净，导致新的初始化操作和旧线程抢资源，或者旧线程还在操作已经失效的设备句柄。下面给你一套具体的解决方案，亲测有效：

1. 先把关键资源的引用管起来 #

首先，你需要在类里保存当前运行的线程、TargetDataLine实例，以及一个控制线程运行的状态标记（要用volatile保证多线程可见性）：

// 类成员变量，统一管理当前音频资源
private TargetDataLine currentDataLine;
private Thread dataReadThread;
private Thread meterDisplayThread;
private volatile boolean isAudioRunning = false; // 标记是否在运行音频处理

2. 实现优雅的资源停止逻辑 #

写一个专门的方法来停止旧的线程和释放音频资源，这是避免崩溃的核心：

private void stopAudioProcessing() {
    // 先标记停止状态
    isAudioRunning = false;

    // 中断并等待数据读取线程退出
    if (dataReadThread != null && dataReadThread.isAlive()) {
        dataReadThread.interrupt();
        try {
            dataReadThread.join(1000); // 最多等1秒，避免线程卡死
        } catch (InterruptedException e) {
            // 捕获中断后，重新标记当前线程的中断状态
            Thread.currentThread().interrupt();
        }
    }

    // 中断并等待仪表显示线程退出
    if (meterDisplayThread != null && meterDisplayThread.isAlive()) {
        meterDisplayThread.interrupt();
        try {
            meterDisplayThread.join(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }

    // 关闭并释放TargetDataLine
    if (currentDataLine != null && currentDataLine.isOpen()) {
        currentDataLine.stop();
        currentDataLine.close();
    }

    // 清空引用，避免内存泄漏
    currentDataLine = null;
    dataReadThread = null;
    meterDisplayThread = null;
}

3. 切换设备时的正确流程 #

当用户选择新的音频接口时，必须先调用上面的停止方法清理旧资源，再初始化新的设备和线程，同时要加锁避免并发切换：

// 加个锁，防止同时触发多次切换操作
private final Object switchLock = new Object();

public void onAudioInterfaceSelected(Mixer newSelectedMixer) {
    synchronized (switchLock) {
        // 第一步：彻底停止旧的音频处理
        stopAudioProcessing();

        // 第二步：初始化新的音频设备和线程
        try {
            // 根据你的需求配置音频格式
            AudioFormat audioFormat = new AudioFormat(44100, 16, 2, true, true);
            DataLine.Info lineInfo = new DataLine.Info(TargetDataLine.class, audioFormat);
            
            // 打开新的TargetDataLine
            currentDataLine = (TargetDataLine) newSelectedMixer.getLine(lineInfo);
            isAudioRunning = true;

            // 启动数据读取线程
            dataReadThread = new Thread(() -> {
                try {
                    currentDataLine.open(audioFormat);
                    currentDataLine.start();
                    byte[] audioBuffer = new byte[4096];

                    // 循环读取数据，同时检查停止标记和中断状态
                    while (isAudioRunning && !Thread.currentThread().isInterrupted()) {
                        int bytesRead = currentDataLine.read(audioBuffer, 0, audioBuffer.length);
                        // 这里处理你的音频数据逻辑...
                    }
                } catch (LineUnavailableException e) {
                    e.printStackTrace();
                } finally {
                    // 最后确保关闭数据线
                    if (currentDataLine != null && currentDataLine.isOpen()) {
                        currentDataLine.stop();
                        currentDataLine.close();
                    }
                    isAudioRunning = false;
                }
            });
            dataReadThread.start();

            // 启动仪表显示线程
            meterDisplayThread = new Thread(() -> {
                while (isAudioRunning && !Thread.currentThread().isInterrupted()) {
                    // 注意：UI操作必须在Swing EDT线程中执行
                    SwingUtilities.invokeLater(() -> {
                        if (currentDataLine != null) {
                            float signalLevel = currentDataLine.getLevel();
                            // 更新你的仪表组件显示...
                        }
                    });
                    // 控制仪表刷新频率
                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        // 捕获中断后，重新标记中断状态，确保线程退出
                        Thread.currentThread().interrupt();
                    }
                }
            });
            meterDisplayThread.start();

        } catch (LineUnavailableException e) {
            e.printStackTrace();
            // 这里可以给用户提示设备打开失败
        }
    }
}

几个关键注意点 #

• 不要用Thread.stop()：这个方法已经被废弃，强制停止线程会导致资源泄漏，一定要用中断标记+优雅退出的方式。
• UI操作必须在EDT线程：如果你的应用是Swing或JavaFX，更新UI组件的代码一定要放在对应的UI线程中，比如Swing用SwingUtilities.invokeLater，JavaFX用Platform.runLater，否则会导致UI线程混乱。
• volatile关键字的作用：isAudioRunning必须用volatile修饰，这样多个线程能实时看到状态变化，避免线程一直卡在循环里。

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