Java中如何使用非阻塞用户输入优雅地终止无限循环

// 检查是否有输入可用
if (System.in.available() > 0) {
    // 读取输入，此时不会阻塞
    System.in.read();
    // ... 处理输入
}

import java.io.IOException;

public class LoopControlExample {

    // 使用volatile确保多线程环境下的可见性
    private static volatile boolean terminateLoading = false;

    /**
     * 暂停指定时长。
     * @param duration 暂停时长，单位毫秒。
     */
    public static void pause(long duration) {
        try {
            Thread.sleep(duration);
        } catch (InterruptedException e) {
            // 在中断时设置终止标志，以便优雅退出
            Thread.currentThread().interrupt(); // 重新设置中断状态
            terminateLoading = true;
        }
    }

    /**
     * 模拟加载动画。
     */
    public static void loadingAnimation() {
        System.out.println("Loading...");
        while (!terminateLoading) { // 循环条件检查终止标志
            for (int i = 0; i < 3 && !terminateLoading; i++) {
                System.out.print(".");
                pause(500);
            }
            if (terminateLoading) break; // 再次检查以防在for循环中被中断
            System.out.print("\b\b\b   \b\b\b"); // 清除三个点
            pause(500); // 清除后稍作停顿
        }
        System.out.println("\nLoading terminated.");
    }

    /**
     * 监听用户输入以终止加载。
     */
    public static void inputListener() {
        System.out.println("Press Enter to stop loading.");
        try {
            // 循环检查是否有输入，直到有输入或主线程中断
            while (!terminateLoading) {
                if (System.in.available() > 0) {
                    // 读取所有可用的输入，直到换行符
                    while (System.in.available() > 0) {
                        int charCode = System.in.read();
                        if (charCode == '\n' || charCode == '\r') {
                            terminateLoading = true; // 检测到回车，设置终止标志
                            break;
                        }
                    }
                }
                pause(100); // 短暂暂停，避免CPU空转过高
            }
        } catch (IOException e) {
            System.err.println("Error reading input: " + e.getMessage());
        } finally {
            // 可以选择关闭System.in，但通常不建议在应用程序生命周期中关闭标准输入流
            // try { System.in.close(); } catch (IOException e) { /* ignore */ }
        }
    }

    public static void main(String[] args) {
        // 创建并启动加载动画线程
        Thread loadingThread = new Thread(LoopControlExample::loadingAnimation);
        loadingThread.start();

        // 创建并启动输入监听线程
        Thread inputThread = new Thread(LoopControlExample::inputListener);
        inputThread.start();

        // 主线程等待两个子线程完成
        try {
            loadingThread.join();
            inputThread.join(); // 也可以选择不join inputThread，如果它只是一个后台监听器
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("Main thread interrupted.");
        }
        System.out.println("Application finished.");
    }
}