class Sidekiq::Processor::SharedWorkState
jruby’s Hash implementation is not threadsafe, so we wrap it in a mutex here
Public Class Methods
Source
# File lib/sidekiq/processor.rb, line 254 def initialize @work_state = {} @lock = Mutex.new end
Public Instance Methods
Source
# File lib/sidekiq/processor.rb, line 275 def clear @lock.synchronize { @work_state.clear } end
Source
# File lib/sidekiq/processor.rb, line 263 def delete(tid) @lock.synchronize { @work_state.delete(tid) } end
Source
# File lib/sidekiq/processor.rb, line 267 def dup @lock.synchronize { @work_state.dup } end
Source
# File lib/sidekiq/processor.rb, line 259 def set(tid, hash) @lock.synchronize { @work_state[tid] = hash } end
Source
# File lib/sidekiq/processor.rb, line 271 def size @lock.synchronize { @work_state.size } end