0

我从教程中复制了这段代码。每次建立新的 TCP 连接时,它都会启动一个新线程。

require 'socket'                # Get sockets from stdlib

server = TCPServer.open(2000)   # Socket to listen on port 2000
loop {                          # Servers run forever
  Thread.start(server.accept) do |client|
    client.puts(Time.now.ctime) # Send the time to the client
    client.puts "Closing the connection. Bye!"
    client.close                # Disconnect from the client
  end
}

它运行良好,但现在我想在超时的情况下终止线程。为此,我需要终止线程(我不能只抛出异常,因为我必须abort_on_exception启用以便调试很容易),但我不知道如何获取线程句柄。

我觉得我应该能够在循环中这样做:

Thread.start(server.accept) do |client, myThread|
    begin
        Timeout::timeout(1) do
            #important stuff
        end
    rescue Timeout::Error
        client.puts "Timeout"
        client.close
        myThread.terminate
    end
end

我也无法替换myThread.terminate为,exit因为这会杀死我的主进程(出于我不完全理解的原因),并且我不希望服务器因为最后一个线程被终止而停止运行。

4

1 回答 1

1

您正在寻找Thread.current.terminate

于 2013-09-04T03:14:29.863 回答