如何在运行一段时间后中断多个并发线程？代码实现是否正确？

兄弟，你给出的这段代码目前是没法实现你想要的「一段时间后停止所有线程」的需求的，我给你拆解下问题，再给你正确的实现思路哈～

现有代码的核心问题 #

你提供的MyClass的run方法只完成了启动线程和等待指定时间这两步，但完全缺失了「停止所有子线程」的核心逻辑——那些SecondClass线程在启动后会一直运行下去，不会因为主线程等待结束就自动停止。另外Java里不能强制终止线程，必须通过优雅的方式通知子线程停止。

正确实现方案 #

这里给你两种常用的优雅停止线程的方式，你可以根据业务场景选择：

方案1：利用线程中断机制

先修改SecondClass，让它在运行过程中响应中断信号：

class SecondClass extends Thread {
    @Override
    public void run() {
        // 循环执行任务，每次检查线程是否被中断
        while (!Thread.currentThread().isInterrupted()) {
            try {
                // 这里替换成你的实际业务逻辑
                System.out.println("线程 " + getName() + " 正在运行");
                Thread.sleep(1000); // 模拟任务耗时
            } catch (InterruptedException e) {
                // 捕获中断异常后，要重新设置中断状态（sleep会清除中断标志）
                Thread.currentThread().interrupt();
                // 退出循环，结束线程
                break;
            }
        }
        System.out.println("线程 " + getName() + " 已停止");
    }
}

再完善MyClass的run方法，在等待结束后给所有子线程发送中断信号：

class MyClass extends Thread {
    private int numberThreads;
    private long time;
    private SecondClass[] secObj;

    public MyClass(int numberThreads, long time) {
        this.numberThreads = numberThreads;
        this.time = time;
    }

    @Override
    public void run() {
        secObj = new SecondClass[numberThreads];
        // 批量启动子线程
        for (int i = 0; i < numberThreads; i++) {
            secObj[i] = new SecondClass();
            secObj[i].start();
        }

        try {
            // 等待指定时长
            Thread.sleep(time);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 给所有子线程发送中断信号
        for (SecondClass thread : secObj) {
            thread.interrupt();
        }

        // 可选：等待所有子线程完全结束后再退出
        for (SecondClass thread : secObj) {
            try {
                thread.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

方案2：使用自定义停止标志位

如果不想用中断机制，可以给SecondClass加一个volatile修饰的标志位（保证多线程间的可见性），通过修改标志位通知线程停止：

class SecondClass extends Thread {
    // volatile关键字确保标志位的修改能被所有线程立即看到
    private volatile boolean isRunning = true;

    // 对外提供停止线程的方法
    public void stopRunning() {
        isRunning = false;
    }

    @Override
    public void run() {
        while (isRunning) {
            try {
                // 替换成你的业务逻辑
                System.out.println("线程 " + getName() + " 正在运行");
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("线程 " + getName() + " 已停止");
    }
}

对应修改MyClass的run方法：

class MyClass extends Thread {
    private int numberThreads;
    private long time;
    private SecondClass[] secObj;

    public MyClass(int numberThreads, long time) {
        this.numberThreads = numberThreads;
        this.time = time;
    }

    @Override
    public void run() {
        secObj = new SecondClass[numberThreads];
        // 启动所有子线程
        for (int i = 0; i < numberThreads; i++) {
            secObj[i] = new SecondClass();
            secObj[i].start();
        }

        try {
            Thread.sleep(time);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 调用自定义方法停止所有子线程
        for (SecondClass thread : secObj) {
            thread.stopRunning();
        }

        // 等待所有子线程结束
        for (SecondClass thread : secObj) {
            try {
                thread.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

总结 #

你原来的代码只完成了需求的前半部分，缺少关键的停止逻辑，所以是不正确的。另外注意：Java已经废弃了stop()这类强制终止线程的方法，因为会导致资源泄漏等问题，优先用上面两种优雅停止的方式。

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