Class: Opal::BuilderScheduler::Prefork::ForkSet
- Inherits:
-
Array
- Object
- Array
- Opal::BuilderScheduler::Prefork::ForkSet
- Defined in:
- opal/lib/opal/builder_scheduler/prefork.rb
Instance Method Summary collapse
- #close ⇒ Object
- #create_fork ⇒ Object
- #from_io(io, type) ⇒ Object
- #get_events(queue_length) ⇒ Object
-
#initialize(count, &block) ⇒ ForkSet
constructor
A new instance of ForkSet.
- #wait ⇒ Object
Constructor Details
#initialize(count, &block) ⇒ ForkSet
Returns a new instance of ForkSet.
23 24 25 26 27 28 29 |
# File 'opal/lib/opal/builder_scheduler/prefork.rb', line 23 def initialize(count, &block) super([]) @count, @block = count, block create_fork end |
Instance Method Details
#close ⇒ Object
70 71 72 |
# File 'opal/lib/opal/builder_scheduler/prefork.rb', line 70 def close each(&:close) end |
#create_fork ⇒ Object
62 63 64 |
# File 'opal/lib/opal/builder_scheduler/prefork.rb', line 62 def create_fork self << Fork.new(self, &@block) end |
#from_io(io, type) ⇒ Object
66 67 68 |
# File 'opal/lib/opal/builder_scheduler/prefork.rb', line 66 def from_io(io, type) find { |i| i.__send__(type) == io } end |
#get_events(queue_length) ⇒ Object
31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'opal/lib/opal/builder_scheduler/prefork.rb', line 31 def get_events(queue_length) # Wait for anything to happen: # - Either any of our workers return some data # - Or any workers become ready to receive data # - But only if we have enough work for them ios = IO.select( map(&:read_io), sample(queue_length).map(&:write_io), [] ) return [[], []] unless ios events = ios[0].map do |io| io = from_io(io, :read_io) [io, *io.recv] end idles = ios[1].map do |io| from_io(io, :write_io) end # Progressively create forks, because we may not need all # the workers at the time. The number 6 was picked due to # some trial and error on a Ryzen machine. # # Do note that prefork may happen more than once. create_fork if length < @count && rand(6) == 1 [events, idles] end |
#wait ⇒ Object
74 75 76 |
# File 'opal/lib/opal/builder_scheduler/prefork.rb', line 74 def wait each(&:wait) end |