`
sillycat
  • 浏览: 2482720 次
  • 性别: Icon_minigender_1
  • 来自: 成都
社区版块
存档分类
最新评论

AKKA Actor Scheduler

 
阅读更多
AKKA Actor Scheduler

If I want the actor work like cron repeat the messages. I will do like this.
    val schedulerSyncActor = Akka.system.actorOf(SchedulerSyncActor.props, name = "scheduler-sync-actor")
    logger.info("init the schedule jobs-----------")
    Akka.system.scheduler.schedule(
      0 seconds,
      60 seconds,
      schedulerSyncActor,
      "fire-in-the-hole"
    )
    logger.info("schedulerSyncActor executing every " + contextio_sync_interval + " seconds")
If I just want to delay the msg for some time
import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global
import play.api.Play.current
import scala.concurrent.duration._

case msg: DelayResumeParseCOMPersistMessage =>{
  logger.debug("System will send the message delay " + msg.delay + " seconds")
  context.system.scheduler.scheduleOnce(msg.delay second, self, msg.message)
}

The idea is that the DelayResumeParseCOMPersistMessage will be received, and we will delay some seconds, and then, the the message content back to itself again. That is how the self work.

References:
http://doc.akka.io/docs/akka/current/scala/scheduler.html
分享到:
评论

相关推荐

    akka-actor_2.11-2.5.19-API文档-中英对照版.zip

    赠送jar包:akka-actor_2.11-2.5.19.jar; 赠送原API文档:akka-actor_2.11-2.5.19-javadoc.jar; 赠送源代码:akka-actor_2.11-2.5.19-sources.jar; 赠送Maven依赖信息文件:akka-actor_2.11-2.5.19.pom; 包含...

    用Scala写的akka actor简单demo

    用Scala写的akka actor简单demo,已经打包成SBT程序,因为上传大小限制依赖包没上传,用户安装了sbt后只需要执行update命令即可

    akka-actor-2.11-2.5.19-API文档-中文版.zip

    赠送jar包:akka-actor_2.11-2.5.19.jar; 赠送原API文档:akka-actor_2.11-2.5.19-javadoc.jar; 赠送源代码:akka-actor_2.11-2.5.19-sources.jar; 赠送Maven依赖信息文件:akka-actor_2.11-2.5.19.pom; 包含...

    Akka Actor Tutorial代码

    Akka Actor 官网quickstart案例源代码

    Akka Actor模型开发库 v2.9.1.zip

    Akka Actor模型开发库 v2.9.1.zip

    akka-viz, Akka actor系统的可视化调试器( wip ).zip

    akka-viz, Akka actor系统的可视化调试器( wip ) akkaAkka actor系统( 实验)的可视化调试器。 当前版本是基于 akka 2.4.10构建的。下载最新版本为: 要开始,你需要为"监视"jar 添加依赖项:resolvers = Resolver

    akka-actor_2.11 jar包

    akka-actor_2.11 jar包

    akka-actor_2.11-2.5.21-API文档-中文版.zip

    赠送jar包:akka-actor_2.11-2.5.21.jar; 赠送原API文档:akka-actor_2.11-2.5.21-javadoc.jar; 赠送源代码:akka-actor_2.11-2.5.21-sources.jar; 赠送Maven依赖信息文件:akka-actor_2.11-2.5.21.pom; 包含...

    akka-actor_2.11-2.4.20-API文档-中英对照版.zip

    赠送jar包:akka-actor_2.11-2.4.20.jar; 赠送原API文档:akka-actor_2.11-2.4.20-javadoc.jar; 赠送源代码:akka-actor_2.11-2.4.20-sources.jar; 赠送Maven依赖信息文件:akka-actor_2.11-2.4.20.pom; 包含...

    Akka Actor 2.5.13的jar包

    Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行时。Akka用Scala语言写成,同时提供了Scala和JAVA的开发...Akka处理并发的方法基于Actor模型。在Akka里,Actor之间通信的唯一机制就是消息传递。

    akka-actor_2.12 jar包

    akka-actor_2.12 jar包

    akka-actor_2.11-2.4.20-API文档-中文版.zip

    赠送jar包:akka-actor_2.11-2.4.20.jar; 赠送原API文档:akka-actor_2.11-2.4.20-javadoc.jar; 赠送源代码:akka-actor_2.11-2.4.20-sources.jar; 赠送Maven依赖信息文件:akka-actor_2.11-2.4.20.pom; 包含...

    akka-js, Scala.js的Akka actor实现.zip

    akka-js, Scala.js的Akka actor实现 但是,这个项目不被维护,另外一个项目 !目前并没有积极地开展这个项目。 在这里提供一个主动维护的到 Scala.js的端口,可以: https://github.com/unicredit/akka.js 。我们...

    akka-actor_2.11-2.5.21-API文档-中英对照版.zip

    赠送jar包:akka-actor_2.11-2.5.21.jar; 赠送原API文档:akka-actor_2.11-2.5.21-javadoc.jar; 赠送源代码:akka-actor_2.11-2.5.21-sources.jar; 赠送Maven依赖信息文件:akka-actor_2.11-2.5.21.pom; 包含...

    akka-actor_2.11-2.5.23.jar

    spark,akka,actor工具类,版本2.11;akka.actor override def receive: Receive = { case mess: Message => { if (mess.message.equals("")) { println(mess.message) } } }

    akka-actor-1.1.2.jar.zip

    标签:akka-actor-1.1.2.jar.zip,akka,actor,1.1.2,jar.zip包下载,依赖包

    akka-actor-1.0-RC2.jar.zip

    标签:akka-actor-1.0-RC2.jar.zip,akka,actor,1.0,RC2,jar.zip包下载,依赖包

    akka-actor_2.13-2.6.1.jar

    Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行时。Akka用Scala语言写成,同时提供了Scala和JAVA的开发...Akka处理并发的方法基于Actor模型。在Akka里,Actor之间通信的唯一机制就是消息传递。

    akka actor模型开发库 v2.6.14 pc端

    该软件是为了解决分布式编程中一系列的编程问题而设计,是非常实用的Java和Scala的Actor模型应用,支持多种运行系统进行使用,且安全性高,操作简单,用起来也是非常的方便的! 1、Actor之间完全独立; 2、Actor由...

    akka-actor_2.13-2.6.5.jar

    Akka是JAVA虚拟机JVM平台上构建高并发、分布式和容错应用的工具包和运行时。Akka用Scala语言写成,同时提供了Scala和JAVA的开发...Akka处理并发的方法基于Actor模型。在Akka里,Actor之间通信的唯一机制就是消息传递。

Global site tag (gtag.js) - Google Analytics