Actor模型[转]

原文链接:http://blog.jeoygin.org/archives/477

Actor这个模型由Carl Hewitt在1973年提出,Gul Agha在1986年发表技术报告“Actors: A Model of Concurrent Computation in Distributed Systems”,至今已有不少年头了。在计算机科学中,它是一个并行计算的数学模型,最初为由大量独立的微处理器组成的高并行计算机所开发,Actor模型的理念非常简单:天下万物皆为Actor。

  Actor之间通过发送消息来通信,消息的传送是异步的,通过一个邮件队列(mail queue)来处理消息。每个Actor是完全独立的,可以同时执行它们的操作。每一个Actor是一个计算实体,映射接收到的消息到以下动作:

  • 发送有限个消息给其它Actor;
  • 创建有限个新的Actor;
  • 为下一个接收的消息指定行为。

  以上三种动作并没有固定的顺序,可以并发地执行。Actor会根据接收到的消息进行不同的处理。

  在一个Actor系统中,包含一个未处理的任务集,每一个任务由以下三个属性标识:

  • tag:用以区别于系统中的其它任务;
  • target:通信到达的地址;
  • communication:包含在target上的Actor处理任务时可获取的信息,。

  简单起见,可以把一个任务视为一个消息,在Actor之间传递包含以上三个属性的值的消息。

  Actor模型有两种任务调度方式:基于线程的调度以及基于事件的调度:

  • 基于线程的调度:为每个Actor分配一个线程,在接收一个消息时,如果当前Actor的邮箱(mail box)为空,则会阻塞当前线程。基于线程的调度实现较为简单,但线程数量受到操作的限制,现在的Actor模型一般不采用这种方式;
  • 基于事件的调试:事件可以理解为上述任务或消息的到来,而此时才会为Actor的任务分配线程并执行。

  综上,我们知道可以把系统中的所有事物都抽象成一个Actor:

  • Actor的输入是接收到的消息。
  • Actor接收到消息后处理消息中定义的任务。
  • Actor处理完成任务后可以发送消息给其它的Actor。

  那么在一个系统中,可以将一个大规模的任务分解为一些小任务,这些小任务可以由多个Actor并发处理,从而减少任务的完成时间。

  举个简单的例子,比如现在要在3台物理节点上运行一个WordCount作业,可以将这个作业细分为Split、Count和Merge三种任务(任务的target是物理节点的地址,communication可能包含文本、单词及计数等),根据需求要有Split Actor、Count Actor和Merge Actor。整个作业的处理流程以下:

  • Split Actor接收到消息后可以文本分割成10份,每份发送给一个Count Actor;
  • Count Actor统计好单词的数目后发送消息给Merge Actor;
  • Merge Actor收集完Count Actor发送的10个消息后,合并每个单词的数目,完成WordCount任务。

  从以上例子可以看出,Actor系统跟数据驱动系统比如数据流相近,可以自定义任务的流向及其处理过程。Actor模型被广泛使用在很多并发系统中,比如Email、Web Service等等。

参考资料

  (1) G. Agha, Actors: A Model of Concurrent Computation in Distributed Systems. Cambridge, MA, SA: MIT Press,1986.

  (2) Wikipedia: http://en.wikipedia.org/wiki/Actor_model

  (3) ActorLite:一个轻量级Actor模型实现(上)

时间: 2024-11-22 22:39:28

Actor模型[转]的相关文章

.NET的Actor模型:Orleans

Orleans是微软推出的类似Scala Akka的Actor模型,Orleans是一个建立在.NET之上的,设计的目标是为了方便程序员开发需要大规模扩展的云服务, 可用于实现DDD+EventSourcing/CQRS系统. 传统的三层体系结构包括无状态的前端,无状态的中间层和存储层在可伸缩性方面是有限制的,由于存储层在延迟和吞吐量方面的限制,这对于每个用户请求都有影响.通常办法是在中间层和存储层之间添加缓存层来提高性能.然而,缓存会失去了大部分的并发性和底层存储层的语义保证.为了防止缓存和存

Orleans框架------基于Actor模型生成分布式Id

一.Actor简介 actor模型是一种并行计算的数学模型. 响应于收到的消息,演员可以:做出决定,创建更多Actor,发送更多消息,并确定如何响应接收到的下一条消息. 演员可以修改自己的状态,但只能通过消息相互影响(避免需要任何锁). actor是一个计算实体,当其收到消息时,可以并发执行如下操作: 1. 发送有限数量的消息给其他actor 2. 创建有限数量的新actor 3. 指定收到下一消息时的行为 在Orleans中使用的是虚拟Actor方式,详细:http://dotnet.gith

ActorLite: 一个轻量级Actor模型实现

Actor模型 Actor模型为并行而生,具Wikipedia中的描述,它原本是为大量独立的微型处理器所构建的高性能网络而设计的模型.而目前,单台机器也有了多个独立的计算单元,这就是为什么在并行程序愈演愈烈的今天,Actor模型又重新回到了人们的视线之中了.Actor模型的理念非常简单:天下万物皆为Actor,Actor之间通过发送消息进行通信.Actor模型的执行方式有两个特点: 每个Actor,单线程地依次执行发送给它的消息. 不同的Actor可以同时执行它们的消息. 对于第1点至今还有一些

Akka v2.4-ARTERY-M4,Actor 模型开发库

Akka v2.4-ARTERY-M4 发布了.Akka 是一个用 Scala 编写的库,用于简化编写容错的.高可伸缩性的 Java和 Scala 的 Actor 模型应用. 暂未发现该版本更新内容,点击下面链接保持关注更新: http://akka.io/news/ https://github.com/akka/akka/releases/tag/v2.4-ARTERY-M4 https://github.com/akka/akka/compare/v2.4-ARTERY-M4...mast

Actor模型

[原文链接] Actor模式是一个解决分布式计算的数学模型,其中Actor是基础,它能回应接收到消息,能够自我决策,创建更多的Actor,发送更多的消息,决定 如何回应下一个接收到的消息.Actor认为一切皆是Actor,类似于面向对象认为一切皆Object一样.OO的执行是顺序的,Actor模型内在设 计就是并行的. Actor是计算实体,它回复接收到的消息,能够并行的: 1. 发生有限的消息给其他Actor 2. 创建有限数目的新Actor 3. 指定小一个消息到达时的行为 这些操作并没有顺

在.NET中实现Actor模型的不同方式

上周,<实现领域驱动设计>(Implementing Domain-Driven Design)一书的作者Vaughn Vernon,发布了Dotsero,这是一个使用C#编写的.基于.NET的Actor模型工具包,它的实现参考了Akka API.Akka工具包是对Actor模型的一种实现,目前为止已经有对应Java和Scala版本的API. 今年早些时候,微软Research部门也发布了一个基于Actor模型的框架,Orleans框架的预览版.这个框架采用了云端编程模型,编写这个框架的目的在

【Scala篇】--Scala中Trait、模式匹配、样例类、Actor模型

一.前述 Scala Trait(特征) 相当于 Java 的接口,实际上它比接口还功能强大. 模式匹配机制相当于java中的switch-case. 使用了case关键字的类定义就是样例类(case classes),样例类是种特殊的类. Actor相当于Java中的多线程. 二.具体阐述 trait特性 1.概念理解 Scala Trait(特征) 相当于 Java 的接口,实际上它比接口还功能强大. 与接口不同的是,它还可以定义属性和方法的实现. 一般情况下Scala的类可以继承多个Tra

《通过C#学Proto.Actor模型》之Prpos

在第一篇Proto.Actor博文中,HelloWorld的第一行真正代码是:    var props = Actor.FromProducer(() => new HelloActor()); 这个返回的变量props就是一个Props的对象,它是负责创Actor实例,以及配置Actor实例,并且产Actor上下文Context(类似asp.net中的Context). Props对象产生通常是用Actor.FromProducer或Actor.FromFunc产生,不过也可能实例化,实体例

Actor模型及原理

1.Actor模型 在使用Java进行并发编程时需要特别的关注锁和内存原子性等一系列线程问题,而Actor模型内部的状态由它自己维护即它内部数据只能由它自己修改(通过消息传递来进行状态修改),所以使用Actors模型进行并发编程可以很好地避免这些问题,Actor由状态(state).行为(Behavior)和邮箱(mailBox)三部分组成 状态(state):Actor中的状态指的是Actor对象的变量信息,状态由Actor自己管理,避免了并发环境下的锁和内存原子性等问题 行为(Behavio