Class: TaskManager

Inherits:
Object
  • Object
show all
Defined in:
lib/avertasks/taskmanager.rb

Constant Summary collapse

@@queue = 
[]
@@thread_lookup = 
Hash.new
@@queue_mutex = 
Mutex.new
@@should_sort = 
10
@@add_count = 
0
@@full_count = 
1

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ TaskManager

Returns a new instance of TaskManager.



10
11
 
# File 'lib/avertasks/taskmanager.rb', line 10

def initialize()
end

Class Method Details

.run_times ⇒ Object 



34
35
36
 
# File 'lib/avertasks/taskmanager.rb', line 34

def run_times()
    return TaskQueue.run_times
end

Instance Method Details

#add_task(*args, &block) ⇒ Object 



12
13
14
15
16
17
18
19
 
# File 'lib/avertasks/taskmanager.rb', line 12

def add_task(*args, &block)
    begin
        task = Task.new(*args, &block) 
        add_to_hungry_queue(task)
    rescue => exception
        raise exception
    end
end

#broadcast_cankill ⇒ Object 



20
21
22
23
24
 
# File 'lib/avertasks/taskmanager.rb', line 20

def broadcast_cankill()
    @@queue_mutex.synchronize do
        @@queue.each { |item| item.cankill = true }
    end
end

#join ⇒ Object 



25
26
27
28
29
30
31
32
 
# File 'lib/avertasks/taskmanager.rb', line 25

def join()
    self.broadcast_cankill()
    @@queue_mutex.synchronize do
        @@thread_lookup.each_value do |thr|
            thr.join
        end
    end
end