如何从外部停止Java应用中运行的Thread One线程？

Java中不建议使用已废弃的Thread.stop()强制终止线程，因为会引发资源泄漏、数据不一致等风险。结合你的业务场景，推荐两种可靠的实现方案：

方案1：利用线程中断机制（推荐） #

首先要保存Thread One对应的ScheduledFuture引用，同时修改Thread One的逻辑，让它能响应中断信号：

1. 修改main方法，保留Thread One的Future实例：

public static void main(String[] args) {
    ScheduledExecutorService ses = Executors.newScheduledThreadPool(100);
    // 保存Thread One的Future，用于后续触发中断
    ScheduledFuture<?> threadOneFuture = ses.schedule(new ThreadOne(refObject), 3, TimeUnit.SECONDS);
    ses.schedule(new ThreadTwo(refObject), 6, TimeUnit.SECONDS);
    ses.schedule(new ThreadThree(refObject), 9, TimeUnit.SECONDS);
    // 避免提前shutdown导致后续无法控制，可根据业务需求调整shutdown时机
    // ses.shutdown();
}

2. 修改Thread One的run方法，加入中断检查：

class ThreadOne implements Runnable {
    private final RefObject refObject;

    public ThreadOne(RefObject refObject) {
        this.refObject = refObject;
    }

    @Override
    public void run() {
        while (true) {
            // 优先检查线程是否被中断，若中断则直接退出
            if (Thread.currentThread().isInterrupted()) {
                // 这里可以添加资源释放逻辑
                System.out.println("Thread One 响应中断，停止执行");
                return;
            }

            // 原有数据库标志检查逻辑
            boolean isStartReqReceived = checkDatabaseStartFlag();
            if (isStartReqReceived) {
                executeBusinessLogic();
            }

            // 短时间休眠，避免频繁查库消耗资源
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // 捕获中断异常后，重新设置中断状态，确保线程能退出
                Thread.currentThread().interrupt();
                return;
            }
        }
    }

    // 模拟数据库查询逻辑
    private boolean checkDatabaseStartFlag() {
        // 替换为你的实际数据库查询代码
        return false;
    }

    // 模拟业务执行逻辑
    private void executeBusinessLogic() {
        // 替换为你的实际业务代码
    }
}

当用户触发STOP动作时，调用threadOneFuture.cancel(true)即可向Thread One发送中断信号，线程会在下一次循环检查时退出。

方案2：自定义线程安全的终止标志 #

如果希望和现有数据库标志的逻辑结合，也可以在refObject中新增一个内存级别的终止标志（或新增数据库字段）：

1. 给RefObject添加线程安全的终止标志：

class RefObject {
    private final AtomicBoolean stopRequested = new AtomicBoolean(false);
    // 原有字段

    public void requestStop() {
        stopRequested.set(true);
    }

    public boolean isStopRequested() {
        return stopRequested.get();
    }
}

2. 修改Thread One的循环逻辑，同时检查终止标志：

@Override
public void run() {
    while (true) {
        // 检查终止标志，若已触发则退出
        if (refObject.isStopRequested()) {
            // 资源释放逻辑
            System.out.println("Thread One 收到停止请求，终止执行");
            return;
        }

        boolean isStartReqReceived = checkDatabaseStartFlag();
        if (isStartReqReceived) {
            executeBusinessLogic();
        }

        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return;
        }
    }
}

用户触发STOP时，调用refObject.requestStop()，Thread One会在下一次循环检查时终止。

关键注意点 #

• 绝对不要使用Thread.stop()，该方法已被废弃，会导致线程在任意位置终止，引发不可控的问题。
• 如果Thread One中有阻塞操作（比如慢SQL、IO），要确保这些操作能响应中断，或者在设置终止标志后能及时跳出阻塞。
• 若使用ScheduledExecutorService，注意不要过早调用shutdown()，否则虽然cancel()依然有效，但后续无法提交新任务；如果需要优雅关闭，可以在所有任务结束后再调用shutdown()。

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