RubyのUDP受信の並列処理について

Question

udp受信の並列処理は可能？

以下のUDP受信プログラムを作成し,実行できることを確認しています。

require 'socket'
require 'ipaddr'

udps = UDPSocket.open()
udps.bind("0.0.0.0", 3610)
mreq = IPAddr.new("224.0.23.0").hton + IPAddr.new("0.0.0.0").hton
udps.setsockopt(Socket::IPPROTO_IP, Socket::IP_ADD_MEMBERSHIP, mreq)

loop{
  packet,adder = udps.recvfrom(65535)
  p msg=packet.unpack("H*")
}

上記プログラミングでは、loop処理で受信をし続けますが、
受信をしつつ、別の処理を同一のコード内で実現をしたい場合は、どのようなコードになりますか？

例えば、受信を継続しつつ、下記プログラミングの
puts "test"
が実行されるコードはどうすればよいですか？

require 'socket'
require 'ipaddr'

udps = UDPSocket.open()
udps.bind("0.0.0.0", 3610)
mreq = IPAddr.new("224.0.23.0").hton + IPAddr.new("0.0.0.0").hton
udps.setsockopt(Socket::IPPROTO_IP, Socket::IP_ADD_MEMBERSHIP, mreq)

loop{
  packet,adder = udps.recvfrom(65535)
  p msg=packet.unpack("H*")
}

puts "test"

Answer 1

スレッドを立てることで、並行実行できます（るりま）。

なお、マルチスレッドにする場合、いくつか制限があります。

• スレッドの内外で普通の変数を使ってデータをやり取りしようとすると、データが壊れることがあります。ロックをかける、スレッドセーフなデータ構造を使うなどの対応が必要となります。
• ふつうのRubyを使った場合、マルチスレッドでは、I/O待ち以外の部分では同時に1コードしか実行されません（もっとも、今回のようなサーバプログラムでは、I/O待ちだらけなので、特に問題はありません）。

equire 'socket'
require 'ipaddr'


msg_thread = Thread.new do
  udps = UDPSocket.open()
  udps.bind("0.0.0.0", 3610)
  mreq = IPAddr.new("224.0.23.0").hton + IPAddr.new("0.0.0.0").hton
  udps.setsockopt(Socket::IPPROTO_IP, Socket::IP_ADD_MEMBERSHIP, mreq)
  loop{
    packet,adder = udps.recvfrom(65535)
    p msg=packet.unpack("H*")
  }
end

puts "test"

# スレッドの終了を待つ
# 待たないと、メインスレッドが終わるときに別スレッドも終了させられてしまう
msg_thread.join