在 Java 中，停止线程需要谨慎处理，因为直接中断线程可能会导致资源泄露或数据不一致等问题。Java 不鼓励使用 Thread.stop() 方法，因为该方法已被废弃，且在 Java 9 及以后的版本中已被删除。下面是几种推荐的方式来停止线程：
1. 使用标志变量
这是最常见和最安全的方式之一。通过设置一个共享的布尔变量来指示线程何时停止运行。
示例代码
public class StopThreadExample {
private volatile boolean stopRequested = false;
public void requestStop() {
stopRequested = true;
}
public void runTask() {
while (!stopRequested) {
// 执行任务...
System.out.println("Task is running...");
try {
// 线程休眠，防止 CPU 占用过高
Thread.sleep(1000);
} catch (InterruptedException e) {
// 如果线程被中断，捕获异常
Thread.currentThread().interrupt();
return; // 返回以结束线程
}
}
}
public static void main(String[] args) throws InterruptedException {
StopThreadExample example = new StopThreadExample();
Thread thread = new Thread(example::runTask);
thread.start();
// 等待一段时间后请求线程停止
Thread.sleep(5000); // 等待 5 秒
example.requestStop();
// 等待线程终止
thread.join();
}
}
2. 使用 Interrupt 机制
通过调用 Thread.interrupt() 方法来中断线程。线程可以监听 InterruptedException 或检查 Thread.isInterrupted() 方法来判断是否被中断。
示例代码
public class InterruptThreadExample {
public void runTask() throws InterruptedException {
while (!Thread.currentThread().isInterrupted()) {
// 执行任务...
System.out.println("Task is running...");
// 线程休眠，防止 CPU 占用过高
Thread.sleep(1000);
}
}
public static void main(String[] args) throws InterruptedException {
InterruptThreadExample example = new InterruptThreadExample();
Thread thread = new Thread(example::runTask);
thread.start();
// 等待一段时间后请求线程停止
Thread.sleep(5000); // 等待 5 秒
thread.interrupt(); // 请求中断线程
// 等待线程终止
thread.join();
}
}
3. 使用 ExecutorService 和 Future
如果你使用了线程池，可以使用 ExecutorService 和 Future 来停止线程。
示例代码
import java.util.concurrent.*;
public class ExecutorServiceExample {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newSingleThreadExecutor();
Future future = executor.submit(() -> {
while (true) {
// 执行任务...
System.out.println("Task is running...");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break; // 结束线程
}
}
});
// 等待一段时间后请求线程停止
Thread.sleep(5000); // 等待 5 秒
future.cancel(true); // 请求取消任务
// 关闭线程池
executor.shutdown();
}
}
注意事项
避免使用 Thread.stop()：该方法已被废弃，并可能导致程序崩溃或资源泄漏。
正确处理中断异常：在捕获 InterruptedException 后应重新设置中断标志。
优雅地结束线程：尽量让线程在完成当前的工作周期后结束，而不是立即中断。
通过上述方法，你可以安全地停止 Java 中的线程。