我想要一个 java.utils.Timer ,它在 java 中具有可重置的时间。我需要设置一个在 X 秒内发生的一次性事件。如果在创建计时器的时间和 X 秒之间没有发生任何事情,则事件正常发生。

但是,如果在 X 秒过去之前,我决定事件应在 Y 秒后发生,那么我希望能够告诉计时器重置其时间,以便事件在 Y 秒内发生。例如。计时器应该能够执行以下操作:

Timer timer = new Timer();  
timer.schedule(timerTask, 5000); //Timer starts in 5000 ms (X)

//At some point between 0 and 5000 ms...  
setNewTime(timer, 8000);  //timerTask will fire in 8000ms from NOW (Y).

我没有找到使用 utils 计时器来执行此操作的方法,就好像您调用 cancel() 一样,您无法再次安排它。

我接近复制此行为的唯一方法是使用 javax.swing.Timer 并涉及停止原始计时器并创建一个新计时器。IE。:

timer.stop();
timer = new Timer(8000, ActionListener);
timer.start();

有更容易的方法吗??

有帮助吗?

解决方案

根据 Timer 文档,从 Java 1.5 开始,您应该更喜欢 ScheduledThreadPoolExecutor 反而。(您可能想使用以下命令创建此执行器 Executors.newSingleThreadScheduledExecutor() 为了方便使用;它创造了一些很像 Timer.)

很酷的是,当您安排任务时(通过调用 schedule()),它返回一个 ScheduledFuture 目的。您可以使用它来取消计划任务。然后,您可以自由提交具有不同触发时间的新任务。

预计到达时间:这 Timer 链接到的文档没有说明任何内容 ScheduledThreadPoolExecutor, , 但是,那 OpenJDK 版本有这样的说法:

Java 5.0 引入了 java.util.concurrent 包裹和其中一个并发公用事业是 ScheduledThreadPoolExecutor 这是用于以给定速率或延迟重复执行任务的线程池。实际上,这是一个更通用的替代品 Timer/TimerTask组合,因为它允许多个服务线程,接受各种时间单元,并且不需要子分类 TimerTask (只是实施 Runnable)。配置 ScheduledThreadPoolExecutor 用一个线程使其相当于 Timer.

其他提示

如果你的 Timer 只会执行一项任务,那么我建议对其进行子类化:

import java.util.Timer;
import java.util.TimerTask;

public class ReschedulableTimer extends Timer
{
    private Runnable  task;
    private TimerTask timerTask;

    public void schedule(Runnable runnable, long delay)
    {
        task = runnable;
        timerTask = new TimerTask()
        {
            @Override
            public void run()
            {
                task.run();
            }
        };
        this.schedule(timerTask, delay);
    }

    public void reschedule(long delay)
    {
        timerTask.cancel();
        timerTask = new TimerTask()
        {
            @Override
            public void run()
            {
                task.run();
            }
        };
        this.schedule(timerTask, delay);
    }
}

您需要对代码进行修改以添加误用检查,但它应该可以实现您想要的效果。这 ScheduledThreadPoolExecutor 似乎也没有内置对重新安排现有任务的支持,但类似的方法也应该适用。

整个代码片段是这样的......我希望这会有所帮助

{

        Runnable r = new ScheduleTask();
        ReschedulableTimer rescheduleTimer = new ReschedulableTimer();
        rescheduleTimer.schedule(r, 10*1000);


    public class ScheduleTask implements Runnable {
        public void run() {
            //Do schecule task

        }
      }


class ReschedulableTimer extends Timer {
        private Runnable task;
        private TimerTask timerTask;

        public void schedule(Runnable runnable, long delay) {
          task = runnable;
          timerTask = new TimerTask() { 
              public void run() { 
                  task.run(); 
                  }
              };

          timer.schedule(timerTask, delay);        
        }

        public void reschedule(long delay) {
            System.out.println("rescheduling after seconds "+delay);
          timerTask.cancel();
          timerTask = new TimerTask() { 
              public void run() { 
                  task.run(); 
              }
          };
          timer.schedule(timerTask, delay);        
        }
      }


}

您需要安排重复性任务吗?在这种情况下,我建议您考虑使用 石英.

我认为不可能做到这一点 Timer/TimerTask, ,但取决于您到底想要实现什么,您可能会喜欢使用 java.util.concurrent.ScheduledThreadPoolExecutor.

这就是我正在尝试的。我有一个类使用 TimerTask 每 60 秒轮询一次数据库。

在我的主类中,我保留了 Timer 的实例,以及 TimerTask 的本地子类的实例。主类有一个方法来设置轮询间隔(比如从 60 到 30)。在其中,我取消了我的 TimerTask (这是我的子类,我在其中重写了 cancel() 方法来进行一些清理,但这应该不重要),然后将其设置为空。我重新创建它的一个新实例,并在现有计时器中以新的时间间隔安排新实例。

因为 Timer 本身没有被取消,所以它使用的线程保持活动状态(其中的任何其他 TimerTasks 也一样),并且旧的 TimerTask 被替换为新的 TimerTask,新的 TimerTask 恰好是相同的,但是 VIRGIN (因为旧的将被执行或调度,它不再是 VIRGIN,按照调度的要求)。

当我想关闭整个计时器时,我取消并清空 TimerTask (与更改计时时所做的相同,再次清理 TimerTask 子类中的资源),然后取消并清空 Timer 本身。

这是可重置定时器的示例。为了您的方便,尝试更改它......

package com.tps.ProjectTasks.TimeThread;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;

/**
 * Simple demo that uses java.util.Timer to schedule a task to execute
 * every 5 seconds and have a delay if you give any input in console.
 */

public class DateThreadSheduler extends Thread {  
    Timer timer;
    BufferedReader br ;
    String data = null;
    Date dNow ;
    SimpleDateFormat ft;

    public DateThreadSheduler() {

        timer = new Timer();
        timer.schedule(new RemindTask(), 0, 5*1000); 
        br = new BufferedReader(new InputStreamReader(System.in));
        start();
    }

    public void run(){

        while(true){
            try {
                data =br.readLine();
                if(data != null && !data.trim().equals("") ){
                    timer.cancel();
                    timer = new Timer();
                    dNow = new Date( );
                    ft = new SimpleDateFormat ("E yyyy.MM.dd 'at' hh:mm:ss a zzz");
                    System.out.println("Modified Current Date ------> " + ft.format(dNow));
                    timer.schedule(new RemindTask(), 5*1000 , 5*1000);
                }

            }catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String args[]) {
        System.out.format("Printint the time and date was started...\n");
        new DateThreadSheduler();
    }
}

class RemindTask extends TimerTask {
    Date dNow ;
    SimpleDateFormat ft;

    public void run() {

        dNow = new Date();
        ft = new SimpleDateFormat ("E yyyy.MM.dd 'at' hh:mm:ss a zzz");
        System.out.println("Current Date: " + ft.format(dNow));
    }
}

此示例每 5 秒打印一次当前日期和时间...但是如果您在控制台中给出任何输入,计时器将延迟执行给定的输入任务...

我出于类似的目的制作了一个自己的计时器类;随意使用它:

public class ReschedulableTimer extends Timer {
  private Runnable mTask;
  private TimerTask mTimerTask;

  public ReschedulableTimer(Runnable runnable) {
    this.mTask = runnable;
  }

  public void schedule(long delay) {
    if (mTimerTask != null)
      mTimerTask.cancel();

    mTimerTask = new TimerTask() {
      @Override
      public void run() {
        mTask.run();
      }
    };
    this.schedule(mTimerTask, delay);
  }
}
许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top