[ruby-list:21487] Re: IO#method for read data from stream

土岐です。

{Date} Thu, 16 Mar 2000 21:26:09 +0900
{Subject} [ruby-list:21481] IO#method for read data from stream
{Message ID} <[e-mail]>
ARIMA Yasuhiro <[e-mail]> wrote...

ARIMA> socket や pipe を使う際に、読込可能な分だけ読むという機能が
ARIMA> ほしかったので以下のメソッドを書いてみました。
ARIMA> こういうメソッドが標準であってもいいと思うのですが、
ARIMA> なんだか不格好なので知恵を貸してください。

IO#fcntlでnon-blocking I/Oのフラグを立てると、
お望みの動作になるのではないかと思います。
わたしはpipe(2)でしか使ってませんが、多分socketでも
使えるのではないかと。コード以下のような感じです。

require "fcntl"

pin, pout = IO::pipe
fork do
  pin.close
  for n in 1..10
    sleep(1)
    pout.print "*" * n
    pout.flush
  end
end
pout.close

flags = pin.fcntl(Fcntl::F_GETFL)
flags |= Fcntl::O_NONBLOCK
pin.fcntl(Fcntl::F_SETFL, flags)

count = 1
begin
  while (data = pin.read)
    print count, ": ", data, "\n"
    count += 1
  end
rescue Errno::EWOULDBLOCK
  sleep(0.1)
  retry
end

ちなみにスレッドを起動していないときは、読み込むべきデータが
まだ来ていない状態でIO#readを呼ぶとErrno::EWOULDBLOCKが発生します。
複数のスレッドが動いていると、データが来ていない状態では
別のスレッドが動くので、Errno::EWOULDBLOCKは発生しません。

--------------------------------------------------
土岐 仁謙    神戸大学物理高エネ研 Ｍ２
http://www.freedom.ne.jp/toki/