正确的互斥使用/良好的编码风格？

Question

在下面的代码中，生产者periodic_fill_page_queue可能会向当前正在使用的队列添加一个页面（阅读：在设置状态being_processed之前在消费者中）。

class Example

  def initialize
    @threads      = ThreadGroup.new
    @page_queue   = Queue.new
    Thread.abort_on_exception = true
  end

  def start
    periodically_fill_page_queue
    periodically_process_page_queue
  end

  def periodically_fill_page_queue
    @threads.add(Thread.new do
      loop do
        if @page_queue.empty?
          Page.with_state(:waiting).each do |p|
            p.queued!
            @page_queue << f
          end
        end
        sleep 2
      end
    end)
  end

  def periodically_process_page_queue
    loop do
      until file = @page_queue.pop
        sleep 2
      end
      page.being_processed
      process(page)
    end
  end

  def process(page)
    sleep 120
    page.processed
  end

end


class Page < ActiveRecord::Base

  state_machine :state, :initial => :waiting do

    event :queued do
      transition :waiting => :queued
    end

    event :being_processed do
      transition :queued => :being_processed
    end

    event :processed do
      transition :being_processed => :processed
    end

  end

end

为了避免这种情况，我会使用 Mutex 对象：

def initialize
  ...
  @mutex = Mutex.new
end

def periodically_process_page_queue
  loop do
    until file = @page_queue.pop
      sleep 2
    end
    @mutex.synchronize { page.being_processed }
    process(page)
  end
end

这是“好的”编码风格，还是有更优雅的方法？

谢谢！

Answer 1

不是这个设计。一些替代设计可能会执行以下操作之一，但自然也有自己的麻烦。

“分叉”

对于每个作业，您启动一​​个新线程或进程，将作业

委托

给它，将任务委托给每个线程中的队列。每个线程都从自己独特的队列中拉取。

Stride

您有一个循环缓冲区，每个线程以不同的时间间隔进行检查。 EG Num_threads + thread.id
这可能不适合你的情况。

范围

线程负责一系列作业。 num_threads * thread.id
这可能不适合你的情况。