なぜ akka を使うべきなのか

Scala programming Akka

馬鹿にはマルチスレッドは複雑すぎるわたしマルチスレッド怖いんです。なんでかっていうと、あれ、これってスレッドセーフだっけ？とか考えないとだめだし、えーっとこの変数は別のスレッドからアクセスされる可能性があるから〜とか考えないとだめ。あとロ…

2013-08-21

Akka 2.2 の pipeline のテストを書く

programming Scala Akka

PipelinePorts を作ってそこにコマンドやイベントを流し込めば普通に結果が返り値で返ってくるのでテストを書きやすい val pipelinePort = { val ctx = new PipelineContext {} PipelineFactory.buildFunctionTriple(ctx, new YourPipelineStage) } // パイ…

2013-08-16

Akka2.2 既に死んでるactorをwatchした場合どうなるのか

programming Scala Akka

ちゃんと Terminated が送られてくる see http://doc.akka.io/docs/akka/2.2.0/general/supervision.html#what-lifecycle-monitoring-means One important property is that the message will be delivered irrespective of the order in which the monitori…

2013-08-16

Akka(2.2) のネットワークサーバーを Graceful に shutdown

programming Scala Akka

こんな感じでどうでしょうね。解説はコメントを参照のこと。 import akka.actor._ import akka.actor.Terminated import akka.io._ import akka.io.IO import akka.util.ByteString import java.net.InetSocketAddress import scala.collection.immutable.{…

2013-08-15