Class: Async::Scheduler

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

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(reactor) ⇒ Scheduler

Returns a new instance of Scheduler.



35
36
37
 
# File 'lib/async/scheduler.rb', line 35

def initialize(reactor)
  @reactor = reactor
end

Instance Attribute Details

#wrappers ⇒ Object (readonly)

Returns the value of attribute wrappers.



39
40
41
 
# File 'lib/async/scheduler.rb', line 39

def wrappers
  @wrappers
end

Class Method Details

.supported? ⇒ Boolean

Returns:

  • (Boolean) 


26
27
28
 
# File 'lib/async/scheduler.rb', line 26

def self.supported?
  true
end

Instance Method Details

#block(blocker, timeout) ⇒ Object 



89
90
91
 
# File 'lib/async/scheduler.rb', line 89

def block(blocker, timeout)
  @reactor.block(blocker, timeout)
end

#clear! ⇒ Object 



45
46
47
 
# File 'lib/async/scheduler.rb', line 45

def clear!
  Fiber.set_scheduler(nil)
end

#close ⇒ Object 



97
98
 
# File 'lib/async/scheduler.rb', line 97

def close
end

#fiber(&block) ⇒ Object 



100
101
102
103
104
105
106
107
108
 
# File 'lib/async/scheduler.rb', line 100

def fiber(&block)
  task = Task.new(@reactor, &block)
  
  fiber = task.fiber
  
  task.run
  
  return fiber
end

#io_wait(io, events, timeout = nil) ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/async/scheduler.rb', line 53

def io_wait(io, events, timeout = nil)
  wrapper = from_io(io)
  
  if events == ::IO::READABLE
    if wrapper.wait_readable(timeout)
      return ::IO::READABLE
    end
  elsif events == ::IO::WRITABLE
    if wrapper.wait_writable(timeout)
      return ::IO::WRITABLE
    end
  else
    if wrapper.wait_any(timeout)
      return events
    end
  end
  
  return false
ensure
  wrapper.reactor = nil
end

#kernel_sleep(duration) ⇒ Object 



85
86
87
 
# File 'lib/async/scheduler.rb', line 85

def kernel_sleep(duration)
  self.block(nil, duration)
end

#process_wait(pid, flags) ⇒ Object

Wait for the specified process ID to exit.



79
80
81
82
83
 
# File 'lib/async/scheduler.rb', line 79

def process_wait(pid, flags)
  Thread.new do
    ::Process::Status.wait(pid, flags)
  end.value
end

#set! ⇒ Object 



41
42
43
 
# File 'lib/async/scheduler.rb', line 41

def set!
  Fiber.set_scheduler(self)
end

#unblock(blocker, fiber) ⇒ Object 



93
94
95
 
# File 'lib/async/scheduler.rb', line 93

def unblock(blocker, fiber)
  @reactor.unblock(blocker, fiber)
end