модуль MonitorMixin

В конкурентном программировании монитор — это объект или модуль, предназначенный для безопасного использования несколькими потоками. Определяющая характеристика монитора — взаимное исключение при выполнении его методов. То есть в каждый момент времени не более одного потока может выполнять любой из его методов. Такое взаимное исключение значительно упрощает рассуждения о реализации мониторов по сравнению с рассуждениями о параллельном коде, который обновляет структуру данных.

Подробнее об общих принципах можно прочитать на странице Википедии, посвящённой мониторам.

Примеры

Простое расширение объекта с помощью object.extend

require 'monitor.rb'

buf = []
buf.extend(MonitorMixin)
empty_cond = buf.new_cond

# consumer
Thread.start do
  loop do
    buf.synchronize do
      empty_cond.wait_while { buf.empty? }
      print buf.shift
    end
  end
end

# producer
while line = ARGF.gets
  buf.synchronize do
    buf.push(line)
    empty_cond.signal
  end
end

Поток-потребитель ожидает, пока поток-производитель добавит строку в buf, в то время как buf.empty?. Поток-производитель (главный поток) считывает строку из ARGF и добавляет её в buf, затем вызывает empty_cond.signal, чтобы уведомить поток-потребитель о новых данных.

Простое подключение модуля к классу

require 'monitor'

class SynchronizedArray < Array

  include MonitorMixin

  def initialize(*args)
    super(*args)
  end

  alias :old_shift :shift
  alias :old_unshift :unshift

  def shift(n=1)
    self.synchronize do
      self.old_shift(n)
    end
  end

  def unshift(item)
    self.synchronize do
      self.old_unshift(item)
    end
  end

  # other methods ...
end

SynchronizedArray реализует Array с синхронизированным доступом к элементам. Этот класс реализован как подкласс Array, который подключает модуль MonitorMixin.