如何在上午8点至上午10点之间每15分钟配置SinglethreadScheduledexecutor，然后全天每1hr跑15分钟

Question

我需要一些帮助，以实施如何实施SinglethreadScheduledexecutor，以在英国时间上午8点至上午10点之间每15分钟，然后全天每1hr跑。

目前，我有以下Scala代码 -

val pollingExecutor = Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("MyTestScheduledThread"))

pollingExecutor.scheduleWithFixedDelay(new MyRunnableJob(), 0, 15, TimeUnit.MINUTES)

Answer 1

我会在工作的工作周围制作一个包装器：

class ScheduledRun(
   job: Runnable, 
   scheduler: ScheduledExecutorService
 )(delay: => Duration) extends Runnable {
   def schedule(): Unit = delay match {
     case d: FiniteDuration => scheduler.schedule(this, d.toMillis, MILLISECONDS)
     case _ => 
   }
   def run(): Unit = {
     job.run()
     schedule()
   }
}

然后您可以做：

new ScheduledRun(myRunnableJob, pollingExecutor)(
   if (isMorningInUK) 15 minutes else 1 hour
).schedule