Ruby中使用Queue实现信号处理的问题排查

你遇到的问题核心在于Ruby线程调度与信号处理的交互特性——虽然信号已经被成功推入队列，但主线程的Queue#pop阻塞调用可能无法被正确唤醒，这和Ruby的信号处理线程绑定、队列内部条件变量的触发逻辑有关。

为什么你的代码没生效？ #

当你按下Ctrl+C时，信号处理程序确实执行了push操作（从你观察到的队列size增加可以确认），但在部分Ruby环境或线程调度场景下：

1. 信号处理程序可能在非主线程（比如你创建的@manager睡眠线程）中执行，Queue内部的条件变量信号无法跨线程正确唤醒主线程的阻塞；
2. 主线程的pop阻塞被信号中断后，没有自动重新检查队列状态，导致一直卡在等待状态。

修复方案1：手动实现可控的信号队列 #

替代Ruby内置的Queue，我们用Mutex+ConditionVariable手动实现信号队列，这种方式更可控，能确保主线程被精准唤醒：

require 'thread'

class CLI
  def initialize
    @manager = Thread.new { sleep }
    @signal_list = []
    @mutex = Mutex.new
    @condition = ConditionVariable.new
    setup_signal_handlers
  end

  def run
    loop do
      signal = nil
      # 线程安全地获取信号
      @mutex.synchronize do
        # 阻塞直到有信号到来
        @condition.wait(@mutex) while @signal_list.empty?
        signal = @signal_list.shift
      end
      handle_signal(signal)
    end
  rescue Interrupt
    puts "Gracefully exiting..."
    exit
  end

  private

  def handle_signal(signal)
    case signal
    when 'INT'
      raise Interrupt
    end
  end

  def setup_signal_handlers
    %w(INT).each do |signal|
      trap signal do
        @mutex.synchronize do
          @signal_list << signal
          # 主动唤醒等待的主线程
          @condition.signal
        end
      end
    end
  end
end

修复方案2：基于原代码的最小修改 #

如果你想继续使用Queue，可以在信号处理程序中主动唤醒主线程，强制Queue#pop重新检查队列：

class CLI
  def initialize
    @manager = Thread.new { sleep }
    @signal_queue = Queue.new
    setup_signal_handlers
  end

  def run
    loop do
      begin
        signal = @signal_queue.pop
        handle_signal(signal)
      rescue ThreadError
        # 主线程被唤醒但队列仍为空，继续等待
        next
      end
    end
  rescue Interrupt
    exit
  end

  private

  def handle_signal(signal)
    case signal
    when 'INT'
      raise Interrupt
    end
  end

  def setup_signal_handlers
    %w(INT).each do |signal|
      trap signal do
        @signal_queue.push signal
        # 主动唤醒主线程，触发pop重新检查队列
        Thread.main.wakeup
      end
    end
  end
end

关键原理说明 #

• Mutex保证了对信号列表的操作是线程安全的，避免多线程竞态条件；
• ConditionVariable的wait方法会释放锁并阻塞线程，直到signal被调用，线程会重新获取锁并继续执行；
• Thread.main.wakeup会中断主线程的阻塞状态，让Queue#pop强制重新检查队列是否有元素，解决了原代码中唤醒失效的问题。

内容的提问来源于stack exchange，提问作者linkyndy