boss_array.rb

require 'monitor'
require 'celluloid'

class BossArray < 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
end


class What
  include Celluloid

  def append(array, item)
    array.unshift item
  end
end

array = BossArray.new(['test'])
wtfs  = What.pool(size: 100)

results = 500.times.map do |i|
  wtfs.future.append(array, i)
end

results.map(&:value)

puts array.size

501
D, [2013-10-18T12:05:16.868703 #3145] DEBUG -- : Terminating 101 actors...
W, [2013-10-18T12:05:16.878673 #3145]  WARN -- : Terminating task: type=:finalizer, meta={:method_name=>:__shutdown__}, status=:callwait