25

假设我有一个任务是从 java.util.concurrent.BlockingQueue 中提取元素并处理它们。

public void scheduleTask(int delay, TimeUnit timeUnit)
{
    scheduledExecutorService.scheduleWithFixedDelay(new Task(queue), 0, delay, timeUnit);
}

如果可以动态更改频率，我如何安排/重新安排任务？

  • 这个想法是获取数据更新流并将它们批量传播到 GUI
  • 用户应该能够改变更新频率
4

5 回答 5

33

使用schedule(Callable<V>, long, TimeUnit)而不是scheduleAtFixedRate或scheduleWithFixedDelay。然后确保您的 Callable在将来的某个时间重新安排自身或新的 Callable 实例。例如：

// Create Callable instance to schedule.
Callable<Void> c = new Callable<Void>() {
  public Void call() {
   try { 
     // Do work.
   } finally {
     // Reschedule in new Callable, typically with a delay based on the result
     // of this Callable.  In this example the Callable is stateless so we
     // simply reschedule passing a reference to this.
     service.schedule(this, 5000L, TimeUnit.MILLISECONDS);
   }  
   return null;
  }
}

service.schedule(c);

这种方法避免了关闭和重新创建ScheduledExecutorService.

于 2009-10-05T10:31:05.027 回答
7

我认为您无法更改固定速率延迟。我认为您需要使用schedule()执行一次，并在完成后再次安排（如果需要，可以修改超时）。

于 2009-10-05T09:58:20.377 回答
3

我最近不得不使用 ScheduledFuture 执行此操作，并且不想包装 Runnable 等。我是这样做的：

private ScheduledExecutorService scheduleExecutor;
private ScheduledFuture<?> scheduleManager;
private Runnable timeTask;

public void changeScheduleTime(int timeSeconds){
    //change to hourly update
    if (scheduleManager!= null)
    {
        scheduleManager.cancel(true);
    }
    scheduleManager = scheduleExecutor.scheduleAtFixedRate(timeTask, timeSeconds, timeSeconds, TimeUnit.SECONDS);
}

public void someInitMethod() {

    scheduleExecutor = Executors.newScheduledThreadPool(1);    
    timeTask = new Runnable() {
        public void run() {
            //task code here
            //then check if we need to update task time
            if(checkBoxHour.isChecked()){
                changeScheduleTime(3600);
            }
        }
    };

    //instantiate with default time
    scheduleManager = scheduleExecutor.scheduleAtFixedRate(timeTask, 60, 60, TimeUnit.SECONDS);
}
于 2018-10-10T17:20:48.747 回答
2

scheduleAtFixedRate如果您尝试以特定间隔处理多个队列任务，您不应该使用吗？scheduleWithFixedDelay只会等待指定的延迟，然后从队列中执行一项任务。

无论哪种情况， a 中的schedule*方法都ScheduledExecutorService将返回一个ScheduledFuture引用。如果要更改费率，可以取消 ScheduledFuture并以不同的费率重新安排任务。

于 2009-10-05T09:56:37.557 回答
0

scheduleWithFixedDelay(...) 返回一个 RunnableScheduledFuture。为了重新安排它，您可以取消并重新安排它。要重新安排它，你可以只用一个新的 Runnable 包装 RunnableScheduledFuture：

new Runnable() {
    public void run() {
        ((RunnableScheduledFuture)future).run();
    }
};
于 2009-10-05T10:00:26.930 回答