1

这与我在这里提出的一个问题有关： Ruby 中的线程锁定（使用soap4r 和QT）

然而，它是特定于该问题的一部分，并得到了一个更简单的例子的支持。测试代码为：

require 'rubygems'
require 'thread'
require 'soap/rpc/standaloneserver'

class SOAPServer < SOAP::RPC::StandaloneServer

    def initialize(* args)
        super
        # Exposed methods
        add_method(self, 'test', 'x', 'y')
    end

    def test(x, y)
        return x + y
    end
end


myServer = SOAPServer.new('monitorservice', 'urn:ruby:MonitorService', 'localhost',         4004)

Thread.new do
    puts 'Starting web services'
    myServer.start
    puts 'Ending web services'
end

sleep(4)

#Thread.new do
    testnum = 0
    while testnum < 4000 do
        testnum += 1
        puts myServer.test(0,testnum)
        sleep(2)
    end
#end

puts myServer.test(0,4001)
puts myServer.test(0,4002)
puts myServer.test(0,4003)
puts myServer.test(0,4004)
gets

当我用注释掉的线程运行它时，一切都运行良好。但是，一旦将线程放入进程中，就会挂起。我戳到 Webrick，发现止损发生在这里（当然，看跌期权是我的）：

while @status == :Running
      begin
        puts "1.1"
        if svrs = IO.select(@listeners, nil, nil, 2.0)
          svrs[0].each{|svr|
        puts "-+-"
            @tokens.pop          # blocks while no token is there.
            if sock = accept_client(svr)
              th = start_thread(sock, &block)
              th[:WEBrickThread] = true
              thgroup.add(th)
            else
              @tokens.push(nil)
            end
          }
        end
        puts ".+."

当使用未注释掉的线程运行时，我得到如下信息：Starting web services

1.1
.+.
1.1
4001
4002
4003
4004
1
.+.
1.1
4

2 回答 2

1

如果问题是由 gets() 调用引起的，并且代码中 gets() 调用的目的是防止 Ruby 解释器退出，则可以为您创建的每个线程调用 Thread.join() 替换它。Join() 将阻塞，直到该线程完成执行，因此它将阻止 Ruby 解释器退出。

例如：

t1 = Thread.new do
    puts 'Starting web services'
    myServer.start
    puts 'Ending web services'
end

t2 = ...
...

t1.join
t2.join

或者，如果只有一个线程控制应用程序的执行，则可以仅加入（）一个线程，而其他线程将在退出时被杀死。

于 2010-01-12T10:26:41.837 回答
0

尾随的 get 阻塞了 Ruby 的 IO。我不确定为什么。如果它被替换为几乎任何程序都可以工作。我使用了一个睡眠循环：

loop do
    sleep 1
end

补充：我应该注意到，基于睡眠增量，我也会有奇怪的睡眠行为。最后我放弃了 Ruby，因为线程行为太不稳定了。

于 2009-10-27T16:05:40.387 回答