buggered_logger_with_one_mutex.rb

require 'thread'

class BuggeredLogger
  def initialize
    @buffer = []
    @mutex = Mutex.new
  end
  
  def maybe_flush
    flush if @buffer.size > 10
  end
  
  def flush
    return unless @buffer.size > 0
    # better lock the slicing
    @mutex.synchronize do
      puts "*** #{@buffer.slice!(0..-1).size}"
    end
  end
  
  def log(msg)
    @buffer << msg
    maybe_flush
  end
end


$logger = BuggeredLogger.new

threads = (1..50).map do |i|
  Thread.new do
    loop do
      $logger.log("HEY MAN, I AM #{i}")
      puts "logged from #{i}"
    end
  end
end

# run the blender for 60 seconds
sleep(30)