BT

如何利用碎片时间提升技术认知与能力? 点击获取答案

Groovy中的Actor模型

| 作者 胡键 关注 0 他的粉丝 发布于 2009年1月20日. 估计阅读时间: 5 分钟 | GMTC大前端的下一站,PWA、Web框架、Node等最新最热的大前端话题邀你一起共同探讨。

性能是所有程序开发人员无法回避的问题,性能糟糕的程序只会将客户拒之门外,让开发商的声誉受损,让投资人的金钱打水漂。然而优秀的性能表现并非能免费获得,即便在当今的多核时代,一个单线程程序也不会因部署到多核机器上而使性能自动提升。不错,在众多提升性能的手段中,使程序并行化是其中最容易想到且最有效的手段之一。然而对于大多数主流编程语言来讲,“说来容易,做起来难”这句老话在多线程编程上可谓体现得淋漓尽致。以Java这一无所不在的语言为例,死锁、资源分配、状态共享、调试、异步调用无一例外都是在多线程编程过程中的拦路虎。这一点想必有过Java多线程编程经验的开发者都有体会。而随着并行需求的越来越高,另一门有着悠久历史的语言也重新得到了主流世界的关注,它就是Erlang。

Erlang以其对并行编程天生的支持而闻名。在其他语言看来棘手的并行编程问题,对Erlang来说则显得是轻而易举。由于无共享、基于消息等特点,使得死锁、状态共享、异步调用等困扰多线程编程的问题在Erlang中不复存在。正是因为使用它编写并行程序容易,使得这些年来国内技术社区对Erlang的关注在不断地升温。当然,任何一门成功语言的背后都离不开坚实的理论基础。Erlang也不例外。支撑其对并行编程有着良好支持的幕后功臣要归功于Actor模型

Actor模型并非什么新鲜事物,它由Carl Hewitt于上世纪70年代早期提出,目的是为了解决分布式编程中一系列的编程问题。其特点如下(摘自这个幻灯片):

  • 系统中的所有事物都可以扮演一个Actor
  • Actor之间完全独立
  • 在收到消息时Actor所采取的所有动作都是并行的,在一个方法中的动作没有明确的顺序
  • Actor由标识和当前行为描述
  • Actor可能被分成原始(primitive)和非原始(non primitive)类别
  • 非原始Actor有
    • 由一个邮件地址表示的标识
    • 当前行为由一组知识(acquaintances)(实例变量或本地状态)和定义Actor在收到消息时将采取的动作组成
  • 消息传递是非阻塞和异步的,其机制是邮件队列(mail-queue)
  • 所有消息发送都是并行的

幸运的是,Erlang并非是实现了Actor模型的唯一语言。在Java平台上,开发者还能够选择Scala。对于那些坚守“纯”Java语言的开发者,他们则可以选择以下的框架:

关于这些框架的比较,可以参见这个帖子

出于对Scala的Actor库的“艳羡”,Vaclav Pech在其项目GParallelizer中也实现了Actor模型。该项目是用Groovy实现的并行处理DSL,当前版本为0.4。GParallelizer提供了多种Actor类,它们的区别在于所用消息队列的类型不同。GParallelizer中Actor的主要方法有:
  • send,发送消息
  • receive,接收消息
  • start,启动Actor
  • act,该方法是protected类型的,它由Actor的线程周期调用,直到Actor上的stop被调用为止。GParallelizer提供了一种“即发即弃”的Actor:OneShotActor,它的stop方法会在首次执行act之后自动被调用。
  • stop,停止Actor

Actor上的生命周期方法有:

  • afterStart
  • beforeStop
  • afterStop

Vaclav Pech并在其博客对Actor的主要使用进行了说明

创建一个打印它收到的所有消息的一个Actor。

 def actor = Actors.actor {
println receive()
}

启动并发送消息。

actor.start()
actor.send('Message')

扩展Actor。

class CustomActor extends BoundedActor {
 @Override protected void act() {
 println receive()
 }
}

def actor=new CustomActor()

除了这些入门的例子,Vaclav Pech还列举了相对实用的两个例子:计算器和并行归并排序。关于这些例子的详情可以从其博客了解一二。

除了Actor,GParallelizer的主要组件还包括:

  • Asynchronizer,基于Java Executors的并行集合处理器
  • Parallelizer,使用JSR-166y并行数组(Parallel Arrays)来对多线程集合处理提供支持。

欲了解该项目详情,请访问该项目主页

阅读更多Groovy和Erlang内容,请浏览InfoQ中文站Groovy专题Erlang专题

评价本文

专业度
风格

您好,朋友!

您需要 注册一个InfoQ账号 或者 才能进行评论。在您完成注册后还需要进行一些设置。

获得来自InfoQ的更多体验。

告诉我们您的想法

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

一年前的,没人关注啊 by lu wenhua

看来;groovy 太小众了,起码国内是这样的。

一年前的,没人关注啊 by lu wenhua

看来;groovy 太小众了,起码国内是这样的。
看了一下,现在已是0.84了。

一年前的,没人关注啊 by Zhou Shuai

我也是一年后,看到了,呵呵。国内用的人多吗,我也是最近决定过年期间学学,看能不能用到新项目中去。grovvy scriptom我觉得不错,刚好需要写个调com的接口,可以用java写了。

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

3 讨论

登陆InfoQ,与你最关心的话题互动。


找回密码....

Follow

关注你最喜爱的话题和作者

快速浏览网站内你所感兴趣话题的精选内容。

Like

内容自由定制

选择想要阅读的主题和喜爱的作者定制自己的新闻源。

Notifications

获取更新

设置通知机制以获取内容更新对您而言是否重要

BT