从定时器线程调用java定时器任务

Question

这是关于java的内置Timer类的。我需要一个方法在特定的时间间隔内被频繁地调用，但是如果执行时间太长，我不希望它们堆积起来，所以解决方法是在所述方法的开始处排队下一个执行。当然这意味着排队发生在同一队列中。这会解决还是会导致问题？

public class SomeClass extends TimerTask { 
    public static SomeClass timer; 
    public void run() { 
     timer.schedule(this,100); 
     //do stuff 
    } 

} 

Answer 1

Java拥有执行程序服务来执行您想要执行的操作。看看方法ScheduledExecutorService#scheduleWithFixedDelay()。与方法ScheduledExecutorService#scheduleAtFixedRate()相反，具有固定延迟的方法不会跟上。

下面是一个例子：

public void run() { 
    Executors.newSingleThreadScheduledExecutor().scheduleWithFixedDelay(
      this::task, 0, 10, TimeUnit.MILLISECONDS); 
} 

public void task() { 
    // run your task 
} 

---

事实上，你的使用情况似乎不属于标准库的方法。但是，您应该可以使用以下课程来完成您想要的任务。

import java.util.concurrent.Executors; 
import java.util.concurrent.ScheduledExecutorService; 
import java.util.concurrent.TimeUnit; 
import java.util.function.Consumer; 

public class TimerExample { 
    private final ScheduledExecutorService executor = Executors 
      .newSingleThreadScheduledExecutor(); 
    private final Runnable task; 
    private final Consumer<Exception> onException; 
    private final long delay; 
    private final TimeUnit unit; 

    public TimerExample(Runnable task, Consumer<Exception> onException, 
      long delay, TimeUnit unit) { 
     this.task = task; 
     this.onException = onException; 
     this.delay = delay; 
     this.unit = unit; 
    } 

    public void start() { 
     executor.execute(this::execute); 
    } 

    private void execute() { 
     executor.schedule(this::execute, delay, unit); 
     try { 
      task.run(); 
     } catch (Exception e) { 
      onException.accept(e); 
     } 
    } 
} 

这里的用法：

new TimerExample(() -> System.out.println("."), 
      Exception::printStackTrace, 20, TimeUnit.MILLISECONDS).start(); 

由于它采用单线程执行服务，它不会，直到前完成启动下执行。另外，它在任务本身执行之前调度下一次执行。

另请参阅this SO-有关为什么您应该更喜欢Timer类上方的执行程序服务的问题。

你还得自己实现关机机制。