接受时间源的Java - Timer类

Question

我需要替换接受时间源的java.util.Timer或java.util.concurrent.ScheduledExecutorService，以便将其从系统时间、或中移除。我使用这个计时器周期性地执行一个方法，但是当应用程序处于“活动”模式时，需要由系统时间驱动，而当应用程序处于“回放”模式时，需要一些其他源。

我确实看到了一些第三方库，比如番石榴秒表，其功能类似于我所要求的功能，但由于我正在开发的信息系统的策略，我更喜欢Java的原生功能。

我可能最终不得不写我自己的，但我在这里问，因为这似乎是一个需要，许多人会.无论是在使用具有替代时间传递概念的应用程序时，还是在使用嵌入式计时器测试单元时。

Answer 1

如果其他人需要它，这是我最后得到的解决方案。

public interface TimeSource {
    long currentTimeMillis();
}

public class AlternateTimeSource implements TimeSource {

    long currentTime = 0;       

    public AlternateTimeSource() {
    }

    public setTime(long time) {
        if (time > currentTime) currentTime = time;
    }

    @Override
    public long currentTimeMillis() {
        return currentTime;
    }
}

public class SystemTimeSource implements TimeSource {

    @Override
    public long currentTimeMillis() {
        return System.currentTimeMillis();
    }
}

class SourcedTimerThread extends Thread {

    TimeSource reference_;
    TimerTask task_;
    long period_;
    long executionTime_;
    boolean done = false;

    SourcedTimerThread(TimeSource reference,TimerTask task,long delay,long period) {
        reference_     = reference;
        task_          = task;
        period_        = period >= 0 ? period : 0;
        executionTime_ = reference_.currentTimeMillis() + (delay >= 0 ? delay : 0);
        setName("SourcedTimerThread_"+reference_.getClass().getSimpleName());
        start();
    }

    public void cancel() {
        done = true;
        interrupt();
    }

    public void run() {

        long currentTime;

        while (!done) {
            try {
                currentTime = reference_.currentTimeMillis();
                if (executionTime_>currentTime) { 
                    // Task hasn't yet fired; wait
                    sleep(1);                   }
                else {
                    task_.run();
                    if (period_ > 0) {
                        // Repeating task, reschedule
                        executionTime_ = ((period_ < 0) ? currentTime-period_ : executionTime_ + period_);
                    }
                    else {
                        // Non-repeating task, done
                        break;
                    }
                }
            } catch (InterruptedException e) {
            }
        }
    }
}

用法：

// Build source
TimeSource source = null;
if (alternate) {
    source = new AlternateTimeSource();
}
else {
    source = new SystemTimeSource();
}

// Configure timer
SourcedTimerThread t = new SourcedTimerThread(source,new TimerTask() {
    @Override
    void run() {
        System.out.println("Yay!");
    }
}, delayMs, periodMs);

// Drive timer if necessary
if (alternate) {
    // Drive timer based on alternate source such as data
    source.setTime(dataRecord.getTime());
}

// When ready to cleanup
t.cancel();

Answer 2

通过执行以下操作，可以使用自定义时间源实现java.util.concurrent.ScheduledExecutorService：

计算自定义时间源和系统时间之间的偏移量或增量(初始化时)，并在ScheduledExecutorService实现中保持增量。当调用schedule (以及接口中的类似方法)时，使用与初始化时计算的相同的偏移量，并在所提供的TimeUnits上应用这些偏移量。这样--您可以依赖于调度程序的现有实现。