Sha256: 707953147828d623d5fbc4acfef9da0b6caca97760671c255ac51bb654de8010

Contents?: true

Size: 448 Bytes

Versions: 5

Compression:

Stored size: 448 Bytes

Contents

# frozen_string_literal: true

module Delayed
  module Master
    class SafeArray < Array
      def initialize(*args)
        @mon = Monitor.new
        super
      end

      def <<(*args)
        @mon.synchronize do
          super
        end
      end

      def delete(*args)
        @mon.synchronize do
          super
        end
      end

      def clear
        @mon.synchronize do
          super
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
delayed_job_master-3.1.2 lib/delayed/master/safe_array.rb
delayed_job_master-3.1.1 lib/delayed/master/safe_array.rb
delayed_job_master-3.1.0 lib/delayed/master/safe_array.rb
delayed_job_master-3.0.1 lib/delayed/master/safe_array.rb
delayed_job_master-3.0.0 lib/delayed/master/safe_array.rb