当前位置：首页 > news >正文

如何判断一个TimerTask是否已经完成

news 2025/7/19 3:02:16

判断TimerTask是否已经完成并不是TimerTask或Timer类直接提供的功能，因为TimerTask一旦被提交给Timer执行，它就在一个独立的线程中运行，而Timer类并不直接提供方法来查询或控制任务的执行状态。

然而，可以通过以下几种方式来间接判断或管理TimerTask的完成状态：

1. 使用`volatile`布尔变量

在TimerTask类中定义一个volatile布尔变量来标记任务是否已经完成。在run方法中设置这个变量，然后在其他地方检查这个变量来判断任务状态。

import java.util.Timer;
import java.util.TimerTask;public class CheckCompletionTimerTask extends TimerTask {// 标记任务是否完成private volatile boolean isCompleted = false;@Overridepublic void run() {// 模拟任务执行System.out.println("Task is running...");try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}// 设置任务完成标志isCompleted = true;}// 检查任务是否完成public boolean isCompleted() {return isCompleted;}public static void main(String[] args) {Timer timer = new Timer();CheckCompletionTimerTask task = new CheckCompletionTimerTask();timer.schedule(task, 1000); // 1秒后开始执行任务try {// 等待任务完成Thread.sleep(4000);// 检查任务状态if (task.isCompleted()) {System.out.println("Task has been completed.");} else {System.out.println("Task is still running or failed to complete.");}} catch (InterruptedException e) {e.printStackTrace();}}
}

2. 使用`Future`和`ExecutorService`

虽然Timer不直接支持Future，但你可以使用ExecutorService来实现类似的功能，这将允许你使用Future来查询任务状态。

import java.util.concurrent.*;public class FutureTimerTaskExample {public static void main(String[] args) throws InterruptedException, ExecutionException {ExecutorService executor = Executors.newSingleThreadExecutor();Future<?> future = executor.submit(new Runnable() {@Overridepublic void run() {System.out.println("Task is running...");try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}}});// 等待任务完成future.get(); // 这将阻塞直到任务完成System.out.println("Task has been completed.");executor.shutdown();}
}