lib/right_chimp/queue/ChimpQueue.rb in right_chimp-2.1.22.2 vs lib/right_chimp/queue/ChimpQueue.rb in right_chimp-2.1.24
- old
+ new
@@ -4,18 +4,19 @@
# chimp work queue
#
class ChimpQueue
include Singleton
- attr_accessor :delay, :retry_count, :max_threads, :group
+ attr_accessor :delay, :retry_count, :max_threads, :group, :processing
def initialize
@delay = 0
@retry_count = 0
@max_threads = 10
@workers_never_exit = true
@threads = []
@semaphore = Mutex.new
+ @processing = {}
self.reset!
end
#
# Reset the queue and the :default group