ユーザーストリームに接続して、タイムラインに流れる呟きを逐次取得するような関数 each_post() を作りました。中の実装はともかくとして↓こんな感じで使います。 each_post() {|st| if st['text'] then puts st['text'] # 呟きを表示 end } で、これを使って ruby の並列・並行処理*1とか、ちょっと触ってみようかなと。というわけで「5 秒に一度、直近の 5 秒間に発生した呟きを表示する」プログラムを書いていました。 1. スレッド まぁとにかく最初は標準の Thread を使ってみましょということで。 スレッド 2 本作ります。ひとつは呟き収集スレッド、もうひとつは呟き表示スレッドです。 require 'thread' q = Queue.new collect_tw_t = Thread.new do each_post(
![ruby の並行・並列ってどんな感じなのかな、とか。 - 偏見プログラマの語り!](https://cdn-ak-scissors.b.st-hatena.com/image/square/300cdfb8e58f0ab49c33315a3f2ee3e9cc7de7ca/height=288;version=1;width=512/http%3A%2F%2Fcdn-ak.f.st-hatena.com%2Fimages%2Ffotolife%2Fk%2Fkura-replace%2F20120305%2F20120305151846.png)