标签:
学习了基于Scala的Actor之上的分布式并发消息驱动框架Akka初体验,应用actor模型,位置透明,做到高并发、可伸缩、容错、单机也可以用,水平扩展、垂直扩展、容错都有很好的表现,spark中的例子如下:
private def initializeEventProcessActor(){
implicat val timeout=Timeout( 30 seconds)
val initEventActorReply=
dagSchedulerActorSupervisor ? Props(new DAGSchedulerEventProcessActor(this))
eventProcessActor = Await.result(initEventActorReply, timeout.duration).
asInstanceOf[ActorRef]
}
initializeEventProcessActor()
def taskStarted(task: Task[_], taskInfo: TaskInfo){
eventProcessActor! BeginEvent(task, tastkInfo)
}
基于Scala的Actor之上的分布式并发消息驱动框架Akka初体验
标签:
原文地址:http://www.cnblogs.com/tom-lee/p/4744260.html