掌握Java中通过用户输入优雅终止无限循环的并发编程实践

public class BlockingLoopExample {

    public static void pause(long duration) {
        try {
            Thread.sleep(duration);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt(); // 重新设置中断标志
        }
    }

    public static void loading() {
        while (true) { // 尝试无限循环显示动画
            pause(500);
            for (int i = 0; i < 3; i++) {
                System.out.print(".");
                pause(500);
            }
            System.out.print("\b\b\b"); // 回退光标，清除点
        }
    }

    public static void main(String[] args) {
        System.out.println("Loading... Press Enter to stop.");
        loading(); // 动画开始
        // 理论上这里应该等待输入，但实际上永远不会执行到这里
        try {
            System.in.read(); // 阻塞等待输入
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("\nStopped.");
    }
}

import java.io.IOException;
import java.io.InputStream;

public class ConcurrentLoadingAnimation {

    // 使用 volatile 关键字确保 stopFlag 对所有线程的可见性
    private static volatile boolean stopFlag = false;

    /**
     * 模拟暂停一段时间的方法
     * @param duration 暂停时长（毫秒）
     */
    public static void pause(long duration) {
        try {
            Thread.sleep(duration);
        } catch (InterruptedException e) {
            // 当线程被中断时，设置中断标志并退出，以便外部可以捕获中断
            Thread.currentThread().interrupt();
            System.err.println("Loading thread interrupted.");
            stopFlag = true; // 强制停止动画
        }
    }

    /**
     * 运行加载动画的线程任务
     */
    static class LoadingTask implements Runnable {
        @Override
        public void run() {
            System.out.println("Loading... Press Enter to stop.");
            while (!stopFlag) { // 只要 stopFlag 为 false，就继续循环
                for (int i = 0; i < 3; i++) {
                    if (stopFlag) break; // 每次打印前检查是否需要停止
                    System.out.print(".");
                    pause(300); // 调整暂停时间以适应动画速度
                }
                if (stopFlag) break; // 循环结束后再次检查
                System.out.print("\b\b\b   \b\b\b"); // 回退光标，清除点并留空，再回退
                pause(300);
            }
            // 动画停止后，清除可能残留的点
            System.out.print("\r                     \r"); // 清除整行并回车
            System.out.println("Loading stopped.");
        }
    }

    /**
     * 监听用户输入的线程任务
     */
    static class InputMonitorTask implements Runnable {
        @Override
        public void run() {
            try (InputStream in = System.in) { // 使用 try-with-resources 确保 InputStream 关闭
                while (!stopFlag) { // 只要 stopFlag 为 false，就继续监听
                    if (in.available() > 0) { // 检查输入缓冲区是否有数据
                        // 读取所有可用的输入，直到遇到换行符或缓冲区清空
                        while (in.available() > 0) {
                            int charCode = in.read();
                            if (charCode == '\n' || charCode == '\r') { // 检测到回车键
                                stopFlag = true; // 设置停止标志
                                break;
                            }
                        }
                    }
                    pause(50); // 短暂暂停，避免CPU空转过高
                }
            } catch (IOException e) {
                System.err.println("Error reading from input: " + e.getMessage());
            }
        }
    }

    public static void main(String[] args) {
        // 创建并启动加载动画线程
        Thread loadingThread = new Thread(new LoadingTask(), "Loading-Animation-Thread");
        loadingThread.start();

        // 创建并启动输入监听线程
        Thread inputMonitorThread = new Thread(new InputMonitorTask(), "Input-Monitor-Thread");
        inputMonitorThread.start();

        // 主线程等待两个子线程完成
        try {
            loadingThread.join(); // 等待动画线程结束
            inputMonitorThread.join(); // 等待输入监听线程结束
        } catch (InterruptedException e) {
            System.err.println("Main thread interrupted.");
            Thread.currentThread().interrupt();
        }

        System.out.println("Program finished.");
    }
}