0

最初は頻繁にタスクが発生するようにスケジュールし、時間の経過とともに頻度を減らしたいと考えています。このためだけに、Quartz に依存関係を追加したくありません。

標準の Java ライブラリを使用して、私が思いついた最善の方法は、一連の 1 回限りのタスクと、それに続く頻度の低い線形スケジュールです。

    ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
    myRunnable = new MyRunnable();
    executor.schedule( myRunnable, 0, TimeUnit.SECONDS );
    executor.schedule( myRunnable, 5, TimeUnit.SECONDS );
    executor.schedule( myRunnable, 10, TimeUnit.SECONDS );
    executor.schedule( myRunnable, 15, TimeUnit.SECONDS );
    executor.schedule( myRunnable, 30, TimeUnit.SECONDS );
    executor.schedule( myRunnable, 45, TimeUnit.SECONDS );
    executor.scheduleWithFixedDelay( myRunnable, 60, 300, TimeUnit.SECONDS );

よりエレガントなアプローチはありますか？

4

2 に答える 2

5

タスクに次の実行をトリガーさせ、完了ごとに常に「待機秒数」を増やすことができますか?

于 2011-06-22T14:56:55.427 に答える
2

@dcn が提案したことの拡張として、スケジューリングを行う委任クラスを作成できます。

public class NonLinearScheduling {

  public static void taperingOffSchedule(final ScheduledExecutorService executor,
                                         final Runnable task,
                                         final long initialDelay,
                                         final TimeUnit unit,
                                         final double decayMultiplier) {
    assert initialDelay > 0;
    assert decayMultiplier > 1.0;
    Runnable repeater = new Runnable() {
        double nextDelay = initialDelay;
        public void run() {
            task.run();
            nextDelay *= decayMultiplier;
            executor.schedule(this, (long) nextDelay, unit);
        }
    };
    executor.schedule(repeater, initialDelay, unit);
  }
}

repeaterまた、は anonymousである代わりに、Runnable将来のスケジュールをキャンセルできるようにするなど、公に知られているタイプになる可能性があることにも注意してください。

public interface Repeater extends Runnable {
  void stopRepeating();
}


public class NonLinearScheduling {
  public static Repeater taperingOffSchedule(...) { ... }

  private static class NonLinearRepeater implements Repeater {
    private final AtomicBoolean _repeat = new AtomicBoolean(true);

    public void stopRepeating() {
      _repeat.set(false);
    }

    public void run() {
      if (_repeat.get()) {
        ...          
      }
    }
  }
}
于 2011-06-22T15:29:57.710 に答える