Class: Async::Cron::Scheduler

Inherits:
Object
  • Object
show all
Defined in:
lib/async/cron/scheduler.rb

Defined Under Namespace

Classes: Loader

Constant Summary collapse

PATH = 
"config/async/cron/scheduler.rb"

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Scheduler 



61
62
63
 
# File 'lib/async/cron/scheduler.rb', line 61

def initialize
  @schedules = Hash.new.compare_by_identity
end

Instance Attribute Details

#schedules ⇒ Object (readonly)

Returns the value of attribute schedules.



65
66
67
 
# File 'lib/async/cron/scheduler.rb', line 65

def schedules
  @schedules
end

Class Method Details

.load(root = Dir.pwd) ⇒ Object 



44
45
46
47
48
49
50
 
# File 'lib/async/cron/scheduler.rb', line 44

def self.load(root = Dir.pwd)
  path = ::File.join(root, PATH)
  
  if ::File.exist?(path)
    return self.load_file(path)
  end
end

.load_file(path) ⇒ Object 



52
53
54
55
56
57
58
59
 
# File 'lib/async/cron/scheduler.rb', line 52

def self.load_file(path)
  scheduler = self.new
  loader = Loader.new(scheduler)
  
  loader.instance_eval(::File.read(path), path)
  
  return scheduler
end

Instance Method Details

#add(schedule, &block) ⇒ Object 



67
68
69
 
# File 'lib/async/cron/scheduler.rb', line 67

def add(schedule, &block)
  @schedules[schedule] = block
end

#run ⇒ Object 



71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/async/cron/scheduler.rb', line 71

def run
  Sync do
    barrier = Async::Barrier.new
    
    @schedules.each do |schedule, block|
      barrier.async do
        schedule.run(&block)
      end
    end
    
    barrier.wait
  end
end