ruby_queue_example.rb

class Tracker
  def track_event(a,b,c)
    @queue ||= Queue.new
    start_pushing_thread
    hash = { :a => a, :b =>, :c => c }
    @queue << hash
  end

  private
  
  def start_pushing_thread
    return if @pushing_thread
    @pushing_thread = Thread.new do
      items = []
    
      loop do              
        # pop will block until there are queue items available
        items << @queue.pop
        
        if items.size > 24
          SdbWrapper::batch_log_to_sdb(items,'tracking_domain')
          items.clear
        end
      end
    end
  end
  
end