scala - Scala循环一定时间

Question

我正在寻找循环一定时间的可能性。例如，我想 println("Hi there!") 5 分钟。

我正在使用 Scala 和 Akka。

我正在考虑使用future，它将在5分钟内完成，同时我会在它上面使用while循环并检查它是否未完成。这种方法对我不起作用，因为我的班级不是演员，而且我无法从循环之外完成未来。

有什么想法，或者可能有针对此类事情的现成解决方案？

当前丑陋的解决方案：

    def now = Calendar.getInstance.getTime.getTime
    val ms = durationInMins * 60 * 1000
    val finish = now + ms

    while (now <= finish) {
       println("hi")
    }

提前致谢！

score 21 · Accepted Answer

@Radian 的解决方案具有潜在的危险，因为当您的应用程序同时多次运行此代码时，它最终会阻塞 ExecutorService 中的所有线程。您可以更好地使用 a Deadline：

import scala.concurrent.duration._

val deadline = 5.seconds.fromNow

while(deadline.hasTimeLeft) {
  // ...
}

score 0 · Accepted Answer

val timeout = future{Thread.sleep(5000)}
while(!timeout.isCompleted){println("Hello")}

这行得通，但我不喜欢它，因为：

没有睡眠的长循环是不好的。
主线程中的长循环阻塞了您的应用程序

另一种解决方案是将您的逻辑（打印功能）移动到一个单独的 Actor 中，并引入一个调度程序来为您处理时间，并引入另一个调度程序 - 一次在一段时间后发送 PoisonPill

有关调度程序的更多信息

score 0 · Accepted Answer

你也可以用actor的方式来做：

case object Init
case object Loop
case object Stop

class Looper extends Actor {
    var needToRun = true

    def receive = {
        case Init =>
            needToRun = true
            self ! Loop
        case Stop =>
            needToRun = false
        case Loop =>
            if(needToRun) {
                //do whatever you need to do
                self ! Loop
            }
    }
}

并使用调度程序发送消息：

looperRef ! Init
system.scheduler.scheduleOnce(5 MINUTES, looperRef, Stop)

scala - Scala循环一定时间

3 回答 3

Related

Reference