| # -*- coding; utf-8 -*- | |
| require 'rinda/tuplespace' | |
| require 'drb/drb' | |
| require 'webrick' | |
| require 'webrick/cgi' | |
| class RichRinda < WEBrick::CGI | |
| def initialize(ts, *args) | |
| super(*args) | |
| @ts = ts |
| module Enumerable | |
| def slice(nth, len) | |
| return to_enum(__method__, nth, len) unless block_given? | |
| each do |*arg| | |
| break if len <= 0 | |
| if nth >= 1 | |
| nth -= 1 | |
| next | |
| end | |
| len -= 1 |
| def write_services | |
| @sockets.map do |s| | |
| Thread.new(s) do |socket| | |
| loop do | |
| msg = socket.recv(1024) | |
| do_write(msg) | |
| end | |
| end | |
| end | |
| end |
| = るびまコード添削: WikiR、咳のターン。 | |
| この連載は第一回の冒頭で説明されている通り、あるコードをテーマにした文通です。 | |
| たいていの文通は人に見せるものではないのだけれど、今回は特別にみなさんに公開します。 | |
| サラリーマンモードのコードレビューではにらむ、指差す、びっくりするなど言葉を使わなくてもわりと伝わりますが、今回は文通ですからなんとか言葉にしていきたいと思います。 | |
| 前回は須藤さんのターンでした。私の小さなWikiを題材に、須藤さんからコメントをいただきました。 | |
| 今回は私のターンです。須藤さんのコメントに私が言い訳していく番です。 |
| require 'drip' | |
| class DripQueue | |
| def initialize(drip=Drip.new(nil)) | |
| @drip = drip | |
| end | |
| def empty | |
| head = @drip.head[0][0] rescue 0 | |
| @drip.write(head, 'cursor') |
| require 'erb' | |
| class MyERB < ERB | |
| class CompilerWithBlock < ERB::Compiler | |
| def add_put_cmd(out, content) | |
| out.push("#{@put_cmd} #{content_dump(content)}") | |
| end | |
| BLOCK_EXPR = /\s+(do|\{)(\s*\|[^|]*\|)?\s*\Z/ | |
| def add_insert_cmd(out, content) |
| require 'rinda/tuplespace' | |
| module Actor | |
| class Channel | |
| def initialize(ts, key) | |
| @ts = ts | |
| @pid = key | |
| end | |
| attr_reader :pid |
| require 'drip' | |
| module Actor | |
| class Ether | |
| def initialize | |
| @drip = Drip.new(nil) | |
| Thread.current['channel'] = create_channel | |
| end | |
| def create_channel |