13518219792
本篇内容介绍了“Scala Actor多线程怎么理解”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
成都创新互联公司长期为上千家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为庐山企业提供专业的成都网站制作、做网站、外贸营销网站建设，庐山网站改版等技术服务。拥有十多年丰富建站经验和众多成功案例,为您定制开发。
Scala Actor是Scala里多线程的基础，核心思想是用消息传递来进行线程间的信息共享和同步。
Scala Actor线程模型可以这样理解：所有Actor共享一个线程池，总的线程个数可以配置，也可以根据CPU个数决定；当一个Actor启动之后，Scala分配一个线程给它使用，如果使用receive模型，这个线程就一直为该Actor所有，如果使用react模型，Scala执行完react方法后抛出异常，则该线程就可以被其它Actor使用。
下面看一些核心代码。
def start(): Actor = synchronized { // Reset various flags. // // Note that we do *not* reset `trapExit`. The reason is that // users should be able to set the field in the constructor // and before `act` is called. exitReason = 'normal exiting = false shouldExit = false scheduler execute { ActorGC.newActor(Actor.this) (new Reaction(Actor.this)).run() } this }其中Reaction实现Runnable接口，scheduler基本相当于是一个线程池，所以调用start方法之后会有一个线程来为该Actor服务。
使用receive模型。
def receive[R](f: PartialFunction[Any, R]): R = { assert(Actor.self == this, "receive from channel belonging to other actor") this.synchronized { if (shouldExit) exit() // links val qel = mailbox.extractFirst((m: Any) => f.isDefinedAt(m)) if (null eq qel) { waitingFor = f.isDefinedAt isSuspended = true suspendActor() } else { received = Some(qel.msg) sessions = qel.session :: sessions } waitingFor = waitingForNone isSuspended = false } val result = f(received.get) sessions = sessions.tail result如果当前mailbox里面没有可以处理的消息，调用suspendActor，该方法会调用wait；如果有消息，这调用PartialFunction进行处理。
使用react模型。
def react(f: PartialFunction[Any, Unit]): Nothing = { assert(Actor.self == this, "react on channel belonging to other actor") this.synchronized { if (shouldExit) exit() // links val qel = mailbox.extractFirst((m: Any) => f.isDefinedAt(m)) if (null eq qel) { waitingFor = f.isDefinedAt continuation = f isDetached = true } else { sessions = List(qel.session) scheduleActor(f, qel.msg) } throw new SuspendActorException }如果当前mailbox没有可以处理的消息，设置waitingFor和continuation，这两个变量会在接收到消息的时候使用；如果有消息，则调用scheduleActor，该方法会在线程池里选择一个新的线程来处理，具体的处理方法也是由PartialFunction决定。不管是哪条路径，react都会立即返回，或者说是立即抛出异常，结束该线程的执行，这样该线程就可以被其它Actor使用。
再来看看接收消息的处理代码。
def send(msg: Any, replyTo: OutputChannel[Any]) = synchronized { if (waitingFor(msg)) { received = Some(msg) if (isSuspended) sessions = replyTo :: sessions else sessions = List(replyTo) waitingFor = waitingForNone if (!onTimeout.isEmpty) { onTimeout.get.cancel() onTimeout = None } if (isSuspended) resumeActor() else // assert continuation != null scheduler.execute(new Reaction(this, continuation, msg)) } else { mailbox.append(msg, replyTo) }如果当前没有在等待消息或者接收到的消息不能处理，就丢到mailbox里去；相反，则进行消息的处理。这里对于receive模型和react模型就有了分支：如果isSuspended为true，表示是receive模型，并且线程在wait，就调用resumeActor，该方法会调用notify；否则就是react模型，同样在线程池里选择一个线程进行处理。
“Scala Actor多线程怎么理解”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站，小编将为大家输出更多高质量的实用文章！
