Recovery默认下，一个persistent acotr在启动时会自动recover，在重启的时候回放journaled messages. 当在回放message时，被送到persistent actor的新message不会被干扰. 要等recovery完成时，新的message才会被接收到...
分类：
其他好文 时间：
2015-02-03 09:26:58
阅读次数：
184
未完成。SimpleActor.scala//actor是一个类似线程的实体，它有一个用来接收消息的信箱。//实现actor的方法是继承Scala.actors.Actor并完成其act方法//通过调用actor的start方法来启动它class SillyActor extends Actor{ ...
分类：
其他好文 时间：
2015-02-02 22:59:54
阅读次数：
296
接上一篇《多线程设计模式总结(二)》，这篇博客再聊一下最复杂的Active Object模式12)Active ObjectActive Object模式，也称为Actor模式。Active Object即主动对象，它不仅拥有独立线程，并且可以从外部接收异步消息，并能配合需要返回处理结果。这里的Ac...
分类：
编程语言 时间：
2015-02-01 20:21:18
阅读次数：
178
Scala语言是在JVM上编程的优秀语言之一，其为并发，表达式和可扩展性而设计。这门语言及其程序库可以让你专注于问题而无需深陷于线程和同步等底层基础结构细节。Scala是一门混合了函数式和面向对象的语言。有以下特性：
1. Scala对函数式编程的支持可以写出非常简洁而有表现力的代码；
2. 对于多线程应用，Scala提供了基于actor的消息传递模型，消除了涉及并发的痛苦问题，利用该模型，可以很方便简单的写出多线程代码，而不用考虑线程之间的数据竞争和加锁释放锁等问题；
3. Scala和java一样...
分类：
其他好文 时间：
2015-02-01 16:15:47
阅读次数：
210
Pykka 项目的目的是为 Python 提供了易用的并发操作抽象层，使用 Actor 模式。 Pykka 提供了 Actor API ，包含两种不同的实现： ThreadingActor is built on the Python Standard Library’sthreadingandQueuemod...
分类：
编程语言 时间：
2015-01-26 10:25:05
阅读次数：
202
在前面的sparkContex和RDD都可以看到，真正的计算工作都是同过调用DAGScheduler的runjob方法来实现的。这是一个很重要的类。在看这个类实现之前，需要对actor模式有一点了解：http://en.wikipedia.org/wiki/Actor_modelhttp://www...
分类：
其他好文 时间：
2015-01-24 00:26:17
阅读次数：
455
花了约7天的时间用java又实现了一遍. 编程方式相比c++的版本有很大不同, 基本上是一种面向future的编程风格. 主要是期望在业务不复杂的
情况下, 可以在一个屏幕做完所有的事, 避免消息指令定义, 减少寻找回调的麻烦. 下面是一个demo.
/** 提交一个ITC事务, 由Gas-Actor向Db-Actor发送消息, 并期待响应, 请求的参数是一个Boolean, 响应的也是...
分类：
编程语言 时间：
2015-01-22 18:25:00
阅读次数：
216
user是一个actorsystem所有actor的祖先akka://HelloSystem叫做athoritypartuser/helloactor叫做pathpart打印ref后面多了一个数字，这个数字是actor的UID，就像你的***上除了你的名字又多了一个***号一样。有时，你需要与一个还没出生的actor对话，或与一个你无法联系到的actor..
分类：
其他好文 时间：
2015-01-19 00:25:36
阅读次数：
195
1.首先这是一个xml文件 Code CorpOrderID Actor ActDate ...
这篇文章讨论了Java应用中并行处理的多种方法。从自己管理Java线程，到各种更好几的解决方法，Executor服务、ForkJoin 框架以及计算中的Actor模型。Java并发编程的4种风格：Threads，Executors，ForkJoin和Actors我们生活在一个事情并行发生的世界。自然...
分类：
编程语言 时间：
2015-01-15 10:36:35
阅读次数：
289
