demo/Akka.md at master · worksap-ate/demo · GitHub
http://akka.io/ Akka は、アクターモデルをベースにした並行処理のための Scala ライブラリです。 アクターモデル アクターモデルとは、並行・分散システムのモデルです。 近年、多数のマシンが協力して動くシステムが一般的になってきましたが、アクターモデルはそのようなシステムを考える際に使いやすいモデルになっています。 アクターモデルは、大雑把に言うと以下の特徴を持っています。 アクターと呼ばれる計算主体が、非同期にメッセージをやり取りすることで計算をすすめます アクター同士で共有する状態はありません メッセージを送るときは、チャネルをではなく**アクターのID(アドレス)**を指定してメッセージを送ります 逆に言うと、アドレスを知らないアクターにはメッセージを送れません アクターはメッセージを受け取って、そのメッセージに応じて以下の3つの動作を起こします。この、「メッセ
akkaにおけるActorの生成時の注意事項 - xuwei-k's blog
akkaをある程度使いこなしてる人なら、当たり前？かもしれませんが、その細かい仕組みがわかりずらいと思うので説明を書いてみます。(versionによってそれほど変わらないはずですが)これを書いてる時点の最新の akka 2.3.4、Scala 2.11.2 としておきます。 akkaの公式ドキュメントに以下の様な例と説明があります http://doc.akka.io/docs/akka/2.3.4/scala/actors.html import akka.actor.Props val props1 = Props[MyActor] val props2 = Props(new ActorWithArgs("arg")) // careful, see below val props3 = Props(classOf[ActorWithArgs], "arg") そこの「careful
ExecutionContextとblockingについて調べたメモ [scala] - だいたいよくわからないブログ
この記事の結論 globalなExecutionContextではブロックする処理をblockingで包むとスレッド数が勝手に増えるから空きスレッドが無くて実行できないといったことを防げる。 ExecutionContext.fromExecutorService(new ForkJoinPool(100)) で生成されるThreadはBlockContextトレイトを継承してないのでblockingを使ってもスレッド数を増やした方が良いという情報がスケジューラに伝わらない。 akkaのdispatcherをExecutionContextとして使うとBlockContext付きのForkJoinPoolを簡単に作れる。 ExecutionContext.fromExecutorServiceでもForkJoinPoolのコンストラクタに自前定義したThreadFactoryを渡すようにす
![ExecutionContextとblockingについて調べたメモ [scala] - だいたいよくわからないブログ](https://cdn-ak-scissors.b.st-hatena.com/image/square/cd3960dc516fcabbcccd7e6f1bc6952fc1efdc10/height=288;version=1;width=512/https%3A%2F%2Fogimage.blog.st-hatena.com%2F6435988827676774280%2F10328537792366453099%2F1499073542)
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Akka HTTP
