1

Mongoにジョブを保存できる、または少なくともMongoをストレージとして使用するように単純に拡張できる、Scalaで使用するための単純なジョブスケジューラを探しています。

誰でも最善の解決策を提案できますか?

4

1 に答える 1

1

非常にシンプルだが拡張可能なスケジューラ システムを Akka で構築できます。

akka.actor._ をインポート
import akka.util.duration._

val system = ActorSystem("SchedulerTest")
ケース対象ジョブ

val runnerActor = system.actorOf(Props(
   新しいアクター{
      def receive = { case Job => println("run " + self.path.name)}
   }
)))

// 500 ミリ秒でアクターへのジョブ メッセージをスケジュールします
system.scheduler.scheduleOnce(500ミリ秒、runnerActor、Job)

//system.scheduler.schedule(0 ミリ秒, 50 ミリ秒, runnerActor, Job) //これは 50 ミリ秒ごとにメッセージを繰り返します

ワーカー アクターは、必要に応じてさらにイベントをスケジュールできます。構成をデータベースにシリアライズするには、さまざまな方法があります。

スケジューラーの Akka 2.0 Doc

于 2012-05-03T19:25:30.743 に答える