Class: MonitorVariable

Inherits:
Object
  • Object
show all
Defined in:
lib/buzzcore/extra/thread_utils.rb

Instance Method Summary collapse

Constructor Details

#initialize(aMonitor) ⇒ MonitorVariable

Returns a new instance of MonitorVariable.



259
260
261
262
263
264
 
# File 'lib/buzzcore/extra/thread_utils.rb', line 259

def initialize(aMonitor)
  @monitor = aMonitor
  @cvRead = @monitor.new_cond
  @cvWrite = @monitor.new_cond
  @empty = true
end

Instance Method Details

#clear ⇒ Object 



299
300
301
302
303
304
305
 
# File 'lib/buzzcore/extra/thread_utils.rb', line 299

def clear
  @monitor.synchronize do 
    @value = nil
    @empty = true
    @cvWrite.signal
  end
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


295
296
297
 
# File 'lib/buzzcore/extra/thread_utils.rb', line 295

def empty?
  @empty
end

#reject_value ⇒ Object 



307
308
309
310
311
312
313
314
315
 
# File 'lib/buzzcore/extra/thread_utils.rb', line 307

def reject_value
  @monitor.synchronize do 
    if !empty?
      clear
    else
      @reject_next = true
    end
  end
end

#value ⇒ Object 



266
267
268
269
270
271
272
273
274
275
276
277
 
# File 'lib/buzzcore/extra/thread_utils.rb', line 266

def value
  @monitor.synchronize do
    while empty?
      @cvRead.wait(@timeout)
    end
    result = @value
    @value = nil
    @empty = true
    @cvWrite.signal
    result
  end
end

#value=(aValue) ⇒ Object 



279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
 
# File 'lib/buzzcore/extra/thread_utils.rb', line 279

def value=(aValue)
  @monitor.synchronize do 
    until empty?
      @cvWrite.wait(@timeout)
    end
    if @reject_next
      clear
    else
      @value = aValue
      @empty = false
      @cvRead.signal
    end
    aValue
  end
end