cask/util/src-jvm/cask/util/Scheduler.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

package cask.util

import java.util.concurrent.{Executors, TimeUnit}

object Scheduler{
  val scheduler = Executors.newSingleThreadScheduledExecutor()
  def schedule(millis: Long)(body: => Unit) = {
    scheduler.schedule(
      new Runnable {
        def run(): Unit = body
      },
      millis,
      TimeUnit.MILLISECONDS
    )
  }
}