Module: ZeevexConcurrency

Extended by:

Delayed::ConvenienceMethods

Defined in:

lib/zeevex_concurrency.rb,
lib/zeevex_concurrency/delayed.rb,
lib/zeevex_concurrency/logging.rb,
lib/zeevex_concurrency/version.rb,
lib/zeevex_concurrency/event_loop.rb,
lib/zeevex_concurrency/nil_logger.rb

Defined Under Namespace

Modules: All, Logging, ThreadPool Classes: Delay, Delayed, EventLoop, Future, NilLogger, Promise, Synchronized

Constant Summary

VERSION =

"0.0.1"

Class Method Summary

• .logger ⇒ Object
• .logger=(logger) ⇒ Object
• .Synchronized(obj) ⇒ Object

  make object synchronized unless already synchronized.

Methods included from Delayed::ConvenienceMethods

delay, delay?, delayed?, future, future?, promise, promise?

Class Method Details

.logger ⇒ Object

# File 'lib/zeevex_concurrency.rb', line 12

def self.logger
  @logger
end

.logger=(logger) ⇒ Object

# File 'lib/zeevex_concurrency.rb', line 16

def self.logger=(logger)
  @logger = ZeevexConcurrency::Synchronized(logger)
end

.Synchronized(obj) ⇒ Object

make object synchronized unless already synchronized

# File 'lib/zeevex_concurrency/synchronized.rb', line 40

def ZeevexConcurrency.Synchronized(obj)
  if obj.respond_to?(:_get_synchronized_object)
    obj
  else
    ZeevexConcurrency::Synchronized.new(obj)
  end
end