Есть особенность, с которой я столкнулся при использовании запланированных исполнителей Java, и мне было интересно, нормально ли то, что я испытал.
Мне нужно запланировать задачи, которые выполняются с заданной скоростью 5 секунд. Ожидается, что эти задачи время от времени будут выполняться дольше 5 секунд, но когда время их выполнения становится меньше 5 секунд, резервный список задач должен выполняться быстро, чтобы наверстать упущенное. При выполнении задач важно знать, каково было первоначальное запланированное время выполнения (вспомните scheduleExecutionTime ()
в java.util.TimerTask
). Наконец, мне нужно отслеживать разницу между запланированным и фактическим временем, чтобы определить, когда график «дрейфует» и насколько.
До сих пор я реализовал все это с помощью исполнителей Java, и следующий класс иллюстрирует общую идею:
public class ExecutorTest {
public static final long PERIOD = 5000;
public static void main(String[] args) {
Executors.newSingleThreadScheduledExecutor().scheduleAtFixedRate(
new Command(), 0, PERIOD, TimeUnit.MILLISECONDS);
}
private static final class Command implements Runnable {
long timestamp = 0;
public void run() {
long now = System.currentTimeMillis();
if (timestamp == 0) {
timestamp = now;
}
// Drift is the difference between scheduled time and execution time
long drift = now - timestamp;
String format = "Ran at %1$tF %<tT,%<tL; drift: %2$dms";
System.out.println(String.format(format, now, drift));
timestamp += PERIOD;
}
}
}
Выполнение приведенного выше кода показывает, что дрейф (который в идеале должен быть как можно ближе к 0) колеблется на несколько секунд, в результате чего задачи выполняются либо преждевременно, либо с опозданием. Я создал график по результатам выполнения этого в течение примерно 150 минут:
Итак, мой первый вопрос: нормально ли это. Моя среда состоит из 32-битной Windows XP и Java 1.5 с обновлением 21 (хотя Java 6 с обновлением 22 дает аналогичные результаты).
Второй вопрос: есть ли простой способ уменьшить дрейф? Если я использую простой java.util.Timer
или даже просто Thread.sleep ()
, дрейфа не будет.
Наконец, есть ли лучший способ отслеживать запланированное время выполнения при использовании запланированных исполнителей?