java中如何停止线程
如何停止 Java 线程
在 Java 中，停止线程的正确方法需要避免使用已废弃的 Thread.stop()，而是通过协作式机制实现。以下是几种常见方法：
使用标志位控制线程终止
定义一个 volatile 标志变量，线程定期检查该标志并决定是否退出：
public class MyThread extends Thread {
private volatile boolean running = true;
public void stopRunning() {
running = false;
}
@Override
public void run() {
while (running) {
// 执行任务
}
}
}
// 使用示例
MyThread thread = new MyThread();
thread.start();
// 需要停止时
thread.stopRunning();使用中断机制（Interrupt）
通过 Thread.interrupt() 发送中断信号，线程需检查中断状态并响应：
public class MyThread extends Thread {
@Override
public void run() {
while (!Thread.currentThread().isInterrupted()) {
try {
// 执行任务
} catch (InterruptedException e) {
// 恢复中断状态
Thread.currentThread().interrupt();
break;
}
}
}
}
// 使用示例
Thread thread = new MyThread();
thread.start();
// 需要停止时
thread.interrupt();使用 ExecutorService 关闭线程池
对于线程池管理的线程，通过 ExecutorService 提供的方法停止：
ExecutorService executor = Executors.newFixedThreadPool(1);
executor.submit(() -> {
while (!Thread.currentThread().isInterrupted()) {
// 执行任务
}
});
// 优雅关闭（等待任务完成）
executor.shutdown();
// 立即关闭
executor.shutdownNow();注意事项
- 避免直接使用
Thread.stop()，可能导致资源未释放或数据不一致。 - 阻塞操作（如
Object.wait()或Socket.read()）需捕获InterruptedException并正确处理。 volatile确保标志变量对所有线程立即可见。- 清理资源应在退出前完成（如关闭文件、释放锁等）。
