Class: DispatchPolicy::InflightTracker::ThreadSafeFlag

Inherits:

Object

• Object
• DispatchPolicy::InflightTracker::ThreadSafeFlag

Defined in:

lib/dispatch_policy/inflight_tracker.rb

Overview

Tiny fallback if concurrent-ruby isn’t available (it’s a Rails dep via active_support so it normally is).

Instance Method Summary

• #initialize ⇒ ThreadSafeFlag constructor

  A new instance of ThreadSafeFlag.

• #make_true ⇒ Object
• #true? ⇒ Boolean

Constructor Details

#initialize ⇒ ThreadSafeFlag

Returns a new instance of ThreadSafeFlag.

# File 'lib/dispatch_policy/inflight_tracker.rb', line 223

def initialize; @mutex = Mutex.new; @value = false; end

Instance Method Details

#make_true ⇒ Object

# File 'lib/dispatch_policy/inflight_tracker.rb', line 225

def make_true; @mutex.synchronize { @value = true }; end

#true? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/dispatch_policy/inflight_tracker.rb', line 224

def true?; @mutex.synchronize { @value }; end