Class: Sidekiq::Processor::SharedWorkState
- Inherits:
-
Object
- Object
- Sidekiq::Processor::SharedWorkState
- Defined in:
- lib/sidekiq/processor.rb
Overview
jruby’s Hash implementation is not threadsafe, so we wrap it in a mutex here
Instance Method Summary collapse
- #clear ⇒ Object
- #delete(tid) ⇒ Object
- #dup ⇒ Object
-
#initialize ⇒ SharedWorkState
constructor
A new instance of SharedWorkState.
- #set(tid, hash) ⇒ Object
- #size ⇒ Object
Constructor Details
#initialize ⇒ SharedWorkState
Returns a new instance of SharedWorkState.
237 238 239 240 |
# File 'lib/sidekiq/processor.rb', line 237 def initialize @work_state = {} @lock = Mutex.new end |
Instance Method Details
#clear ⇒ Object
258 259 260 |
# File 'lib/sidekiq/processor.rb', line 258 def clear @lock.synchronize { @work_state.clear } end |
#delete(tid) ⇒ Object
246 247 248 |
# File 'lib/sidekiq/processor.rb', line 246 def delete(tid) @lock.synchronize { @work_state.delete(tid) } end |
#dup ⇒ Object
250 251 252 |
# File 'lib/sidekiq/processor.rb', line 250 def dup @lock.synchronize { @work_state.dup } end |
#set(tid, hash) ⇒ Object
242 243 244 |
# File 'lib/sidekiq/processor.rb', line 242 def set(tid, hash) @lock.synchronize { @work_state[tid] = hash } end |
#size ⇒ Object
254 255 256 |
# File 'lib/sidekiq/processor.rb', line 254 def size @lock.synchronize { @work_state.size } end |