[ruby-list:13762] accepting multiple TCPserver

	ひとつのプログラムの中で、複数のTCPserverを同時に待ち受けたい
	ことがあります。たとえば、
		s1 = TCPserver.new(8888)
		s2 = TCPserver.new(8889)
	としたふたつのTCPsever classのインスタンスをthread使って待ちたい、
	ということです。
	ところが、添付のようなコードでやってみるとaccept system callが
	起きません。Thread.startをforkにするとうまく動きます。

	症状としては、
	- Thread.startのあとls.acceptしたところで、ext/socket/socket.cの
	  s_accept()にたどりつきます。
	  ここで、生成されたthreadはrb_thread_wait_fd()に行ったきり、
	  二度とrescheduleされません(のでaccept system callは起きません)。
	  最初に走っているthreadはさっくり
		(0 .. sockpool.size - 1).each do |i|
	  を終ってしまって結局なにもしてくれません。
	というかんじです。
	FreeBSD 2.2.xとBSDI BSD/OS 3.1、ruby 1.0、1.2.5と1.3.2(昨日)で
	確認しています。

	多分わたくしがrubyアマチュアでスクリプト的に間違えているのだと
	ですが、どこがいけないのかごぞんじな方、ヒントを頂けないでしょうか?

	(C一般の)multi thread programmingもあまり知らないので、ちょっと
	追ってみましたがどうするのが適切かわかりませんでした。

itojun


---
# simple httpd

# The code demonstrates how a multi-protocol daemon should be written.
# CAVEAT:
# "fork" cannot be replaced with "Thread.start" because TCPserver does not
# support multi-threading in TCPserver.accept (at least in ruby 1.2.5).
# Frankly, fork isn't really necessary.  I hoped to use Thread.start but
# I just couldn't.

require "socket"
require "thread"

# For IPv6
#port = 8888
#res = Socket.getaddrinfo(nil, port, nil, Socket::SOCK_STREAM, nil, Socket::AI_PASSIVE)
#sockpool = []
#names = []
#res.each do |i|
#  s = TCPserver.new(i[3], i[1])
#  n = Socket.getnameinfo(s.getsockname, Socket::NI_NUMERICHOST|Socket::NI_NUMERICSERV).join(" port ")
#  sockpool.push s
#  names.push n
#end

# for IPv4 test
port = 8888
sockpool = []
names = []
(0 .. 2).each do |i|
  s = TCPserver.new(port + i)
  t = s.addr
  n = sprintf("%s port %d", t[3], t[1])
  sockpool.push s
  names.push n
end

(0 .. sockpool.size - 1).each do |i|
  mysock = sockpool[i]
  myname = names[i]
  STDERR.print "socket #{mysock} started, address #{myname}\n"
# fork do
  Thread.start do
    ls = mysock	# copy to dynamic variable
    STDERR.print "socket #{myname} started, pid #{$$}\n"
    while TRUE
      as = ls.accept
      Thread.start do
	STDERR.print "socket #{myname} accepted, thread ", Thread.current, "\n"
	s = as	# copy to dynamic variable
	str = s.gets
	STDERR.print "socket #{myname} got string\n"
	s.write("Content-type: text/plain\n\n")
	s.write("this is test: my name is #{myname}, you sent:\n")
	s.write("---start\n")
	s.write(str)
	s.write("---end\n")
	s.close
	STDERR.print "socket #{myname} processed, thread ", Thread.current, " terminating\n"
      end
    end
    exit 0
  end
end

sleep 1		# just for message sequencing...

STDERR.print "I have #{sockpool.size} children\n"
(0 .. sockpool.size - 1).each do |i|
  STDERR.print Process.wait, " seems to be dead\n"
end
STDERR.print "all children seems to be dead, bye\n"