blob: 74db37e18330fccef0dc3609bfe18152c8f8dfb0 (
plain) (
tree)
|
|
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
)
}
}
|