Module: EM::Nodes::Client::TaskFeature

Defined in:
lib/em-nodes/client/task.rb

Instance Method Summary collapse

Instance Method Details

#initialize(*args) ⇒ Object 



3
4
5
6
7
 
# File 'lib/em-nodes/client/task.rb', line 3

def initialize(*args)
  super(*args)
  @mutex = Mutex.new
  @tasks_hash = {}
end

#on_task(task_id, data) ⇒ Object 



9
10
11
12
 
# File 'lib/em-nodes/client/task.rb', line 9

def on_task(task_id, data)
  # redefine me
  # after task done, should call send_task_result(task_id, result)
end

#send_task_result(task_id, result) ⇒ Object 



18
19
20
21
 
# File 'lib/em-nodes/client/task.rb', line 18

def send_task_result(task_id, result)
  send_task_result_internal(task_id, result)
  @mutex.synchronize { @tasks_hash.delete(task_id) }
end

#tasks ⇒ Object 



14
15
16
 
# File 'lib/em-nodes/client/task.rb', line 14

def tasks
  @tasks_hash.values
end