Module: Syntropy::SideRun

Defined in:
lib/syntropy/side_run.rb

Class Method Summary collapse

Class Method Details

.call(machine, &block) ⇒ Object 



8
9
10
11
12
13
14
15
16
 
# File 'lib/syntropy/side_run.rb', line 8

def call(machine, &block)
  setup if !@queue

  # TODO: share mailboxes, acquire them with e.g. with_mailbox { |mbox| ... }
  mailbox = Thread.current[:fiber_mailbox] ||= UM::Queue.new
  machine.push(@queue, [mailbox, block])
  result = machine.shift(mailbox)
  result.is_a?(Exception) ? (raise result) : result
end

.handle_request(machine, queue) ⇒ Object 



37
38
39
40
41
42
43
 
# File 'lib/syntropy/side_run.rb', line 37

def handle_request(machine, queue)
  response_mailbox, closure = machine.shift(queue)
  result = closure.call
  machine.push(response_mailbox, result)
rescue Exception => e
  machine.push(response_mailbox, e)
end

.setup ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/syntropy/side_run.rb', line 18

def setup
  @queue = UM::Queue.new
  count = (Etc.nprocessors - 1).clamp(2..6)
  @workers = count.times.map {
    Thread.new { side_run_worker(@queue) }
  }
end

.side_run_worker(queue) ⇒ Object 



26
27
28
29
30
31
32
33
34
35
 
# File 'lib/syntropy/side_run.rb', line 26

def side_run_worker(queue)
  machine = UM.new
  loop { handle_request(machine, queue) }
rescue UM::Terminate
  # # We can also add a timeout here
  # t0 = Time.now
  # while !queue.empty? && (Time.now - t0) < 10
  #   handle_request(machine, queue)
  # end
end