Reactive Streamsとは？ - たけぞう瀕死ブログ
Reactive Streamsというのはノンブロッキングなback pressure可能な非同期ストリーム処理の標準的な仕様を提供しようというもので、実装としてはAkka Streams、RxJava、Reactor Composable、Ratpackなどがあります。 Reactive StreamsについてはAkkaのコミッタであるKonrad Malawskiさんの以下のスライドがとてもわかりやすいです。 2014 akka-streams-tokyo-japanese from Konrad Malawski ストリーム処理（というか非同期メッセージング全般に言えることですが）では受信側の処理能力を超えるデータを送信し続けるといずれキャパシティを超えてオーバーフローが発生してしまうため、送信側に比べて受信側の処理能力が低い場合は送信側が手加減してデータを送信する必要があります。な
「プログラミングErlang」のRing Benchmark をAkkaでやってみた - Milestones to EVERPEACE 〜alius via〜
「プログラミングErlang」のRing Benchmarkをやってみた の続編です。今度は、Akkaでやってみました。 github.com/everpeace/ring-benchmark-in-akka ErlangでプロセスといっていたのがAkkaではアクターになります。 ちょっとだけ違うのは、Erlangのプロセスは Pid = spawn(somefunction) ってやると、somefunctionが実行されると終わっちゃうけれど、Akkaのアクターは class Hoge extends Actor{ def receive ={ case 'msg => println('msg) } } とやっても終わらずにメッセージを待ち続けるところ。あるメッセージを受け取ったときに終了したいなら、こんな風に自分にPoisonPillを飲ませてやればOK. class Hoge e
並行処理初心者のためのAkka入門
Concurrent programing explanation for akka beginers. 並行処理初心者のためのAkka入門 akka meetup 2014/09/28(日) http://connpass.com/event/8622/ このイベントの導入説明のために書かれました。 内容には、並行処理、アクターモデル、Akkaの機能の説明となっています。Read less
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Error handling in Erlang and Scala
