Запланированный Исполнитель в Scala

Question

В Java я могу использовать Scheduled Executor для планирования задач, которые будут выполняться после заданной задержки. Я могу использовать его в Scala, но мне интересно, есть ли для этого API Scala.

Есть ли какой-либо Scala API (в отличие от Scheduled Executor в Java) для планирования задач?

Answer 1

Akka есть что-то подобное с планировщиками:

http://doc.akka.io/api/akka/2.1.4/#akka.actor.Scheduler

Вы можете получить одну из системы актер:

val actorSystem = ActorSystem() 
val scheduler = actorSystem.scheduler 
val task = new Runnable { def run() { log.info("Hello") } } 
implicit val executor = actorSystem.dispatcher 

scheduler.schedule(
    initialDelay = Duration(5, TimeUnit.SECONDS), 
    interval = Duration(10, TimeUnit.SECONDS), 
    runnable = task) 

Если вы используете Акку или что-то на его основе, как игры, это был бы путь.

Answer 2

Раньше в игру была дубликация вопроса.

scala> implicit class Expiry(val d: Deadline) extends AnyVal { 
    | def expiring(f: =>Unit) = 
    | future(Await.ready(Promise().future, d.timeLeft)) onComplete (_ => f) 
    | } 
defined class Expiry 

scala> val x = new SyncVar[Boolean]() 
x: scala.concurrent.SyncVar[Boolean] = scala.concurrent.SyncVar@597d9abe 

scala> 10 seconds fromNow expiring { 
    | println("That's all, folks.") 
    | x.put(true) 
    |  } 

scala> x.take() 
That's all, folks. 
res1: Boolean = true 

Answer 3

Я искал scala api для запланированного выполнения.

ScheduledExecutor в Java:

• использует пул потоков для запуска планировщика и управления таймаутами, и поэтому не требует потока на тайм-аут
• Нет Akka не нужно

я написал небольшая оболочка scala для планирования отдельных задач. Смотрите суть: https://gist.github.com/platy/8f0e634c64d9fb54559c

Answer 4

Вы можете использовать Task scalaz, в

import scala.concurrent.duration.{FiniteDuration, SECONDS} 
import scalaz.concurrent.Task 
Task.schedule(Console.println("time's up"), FiniteDuration(5, SECONDS)).runAsync { _ => }