如何在Java中优雅地终止带有用户输入的无限循环

import java.io.IOException;

public class LoopWithNonBlockingInput {

    private static volatile boolean running = true; // 使用volatile确保多线程可见性

    public static void pause(long duration) {
        try {
            Thread.sleep(duration);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt(); // 重新设置中断标志
            System.err.println("线程被中断: " + e.getMessage());
        }
    }

    public static void loading() {
        System.out.println("加载中，按回车键停止...");
        while (running) {
            for (int i = 0; i < 3; i++) {
                if (!running) break; // 检查运行状态，提前退出
                System.out.print(".");
                pause(500);
            }
            if (!running) break;
            System.out.print("\b\b\b   \b\b\b"); // 清除三个点
            // 检查是否有输入
            try {
                if (System.in.available() > 0) {
                    while (System.in.available() > 0) { // 清空输入缓冲区
                        System.in.read();
                    }
                    running = false; // 收到输入，设置停止标志
                }
            } catch (IOException e) {
                System.err.println("读取输入时发生错误: " + e.getMessage());
                running = false; // 出现错误也停止
            }
        }
        System.out.println("\n加载已停止。");
    }

    public static void main(String[] args) {
        loading();
    }
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

public class LoopWithMultiThreadedInput {

    private static volatile boolean running = true; // 共享的控制标志

    public static void pause(long duration) {
        try {
            Thread.sleep(duration);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("线程被中断: " + e.getMessage());
        }
    }

    // 负责监听用户输入的线程
    static class InputMonitor implements Runnable {
        @Override
        public void run() {
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(System.in))) {
                System.out.println("加载中，按回车键停止...");
                reader.readLine(); // 阻塞式读取一行，直到用户按下回车
                running = false;    // 用户输入后，设置停止标志
            } catch (IOException e) {
                System.err.println("输入监听器发生错误: " + e.getMessage());
                running = false;
            }
        }
    }

    public static void loadingAnimation() {
        while (running) {
            for (int i = 0; i < 3; i++) {
                if (!running) break;
                System.out.print(".");
                pause(500);
            }
            if (!running) break;
            System.out.print("\b\b\b   \b\b\b"); // 清除三个点
        }
        System.out.println("\n加载已停止。");
    }

    public static void main(String[] args) {
        // 启动输入监听线程
        Thread inputThread = new Thread(new InputMonitor());
        inputThread.start();

        // 在主线程中运行加载动画
        loadingAnimation();

        // 等待输入线程结束，确保所有资源被释放
        try {
            inputThread.join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("主线程等待输入线程时被中断: " + e.getMessage());
        }
    }
}