如何在akka和Scala中实现多线程？

Question

def receive = {
    case Rumor => {     
        count+=1; 
            if ...
            else self ! Sleep(FiniteDuration(20, "millis"))
    }
    case Sleep(duration) => {
        case object WakeUp
        context.system.scheduler.scheduleOnce(duration, self, WakeUp)
        context.become(
        {
            case WakeUp => context.unbecome()
                           others ! Rumor
        }, discardOld = false   
        )
    }       
    case _=> .....
 }

import scala.math._
import akka.actor._
import scala.util.Random
import scala.concurrent.duration._

error: Cannot find an implicit ExecutionContext, either require one yourself or import ExecutionContext.Implicits.global
        context.system.scheduler.scheduleOnce(duration, self, WakeUp)

Answer 1

你整件事都做错了。Actors是专门为去除手动线程管理引起的大多数问题而设计的。其中一个特点是，参与者总是按顺序工作。不能强制执行元一次处理多个消息。Akka甚至提供了关于消息及其顺序的几个保证。这允许完全的线程安全，如果您不做任何愚蠢的事情，比如使用可变消息或直接调用其他actor对象。

当然，您可以在单独的线程中运行不同的参与者（使用正确的dispatcher)，它们将真正并行地处理它们的消息。但您不能从多个线程运行单个执行元,无论您做什么。

您真的应该阅读优秀的Akka文档，特别是关于一般概念的部分。如果你读懂了，你就不会有这样的问题了。