concurency_example.rb

      THREADS_NUM.times.map {
        Thread.new do
          while !@objects.empty?
            object = @objects.pop
            @mutex.synchronize do
              print "#{Time.now.strftime("%H:%M")} - Saving data: #{@objects.length} items left.         "
              print "\r"
            end

            if object.save
              @mutex.synchronize { @successful_imports += 1 }
            else
              error_data = {
                :invent => object.try(:equipment).try(:invent),
                :errors => object.errors.full_messages.map(&:to_s).join(', ')
              }
              @bad_imports << error_data
            end
          end
        end
      }.each {|thread| thread.join }