Avi*_*lax 5 concurrency scala actor
AKA按设定的间隔做某事.
例如,假设我想每60秒扫描一个目录.
在Java中,我会使用ScheduledExecutorService如下:
Executor pool = Executors.newScheduledThreadPool(10)
pool.scheduleAtFixedRate(scanner, 0, 60, TimeUnit.SECONDS)
Run Code Online (Sandbox Code Playgroud)
这很好.
问题是,我想我想在我的程序中尝试使用Scala actor,但是我对如何组合actor和Java Executor,或者它们是否应该这样做有点困惑.
我想也许我可以有一个简单的跑步者,它只会每隔N秒向一个演员发送一条消息- 这有意义吗?
我想也许我可以有一个简单的跑步者,它只会每 N 秒向演员发送一条消息 - 这有意义吗?
是的,顺便考虑一下使用 Akka 作为 Actor。它有更简单的 API、更好的性能并且有很多美味的东西。