class Fiber::ExecutionContext::Parallel

• Fiber::ExecutionContext::Parallel
• Reference
• Object

Overview

Parallel execution context.

Fibers running in the same context run both concurrently and in parallel to each others, in addition to the other fibers running in other execution contexts.

The context internally keeps a number of fiber schedulers, each scheduler being able to start running on a system thread, so multiple schedulers can run in parallel. The fibers are resumable by any scheduler in the context, they can thus move from one system thread to another at any time.

The actual parallelism is controlled by the execution context. As the need for parallelism increases, for example more fibers running longer, the more schedulers will start (and thus system threads), as the need decreases, for example not enough fibers, the schedulers will pause themselves and parallelism will decrease.

For example: we can start a parallel context to run consumer fibers, while the default context produces values. Because the consumer fibers can run in parallel, we must protect accesses to the shared value variable. Running the example without Atomic#add would produce a different result every time!

require "wait_group"

consumers = Fiber::ExecutionContext::Parallel.new("consumers", 8)
channel = Channel(Int32).new(64)
wg = WaitGroup.new(32)

result = Atomic.new(0)

32.times do
  consumers.spawn do
    while value = channel.receive?
      result.add(value)
    end
  ensure
    wg.done
  end
end

1024.times { |i| channel.send(i) }
channel.close

# wait for all workers to be done
wg.wait

p result.get # => 523776

Included Modules

• Fiber::ExecutionContext

Defined in:

Constructors

• .new(name : String, maximum : Int32) : self

  Starts a context with a maximum number of threads.

• .new(name : String, size : Range(Nil, Int32)) : self

  Starts a context with a maximum number of threads.

• .new(name : String, size : Range(Int32, Int32)) : self

  Starts a context with a minimum and maximum number of threads.

Instance Method Summary

• #capacity : Int32

  The maximum number of threads that can be started.

• #inspect(io : IO) : Nil

  Appends a String representation of this object which includes its class name, its object address and the values of all instance variables.

• #name : String
• #size : Int32

  The number of threads that have been started.

• #to_s(io : IO) : Nil

  Appends a short String representation of this object which includes its class name and its object address.

Constructor Detail

Instance Method Detail

class Person
  def initialize(@name : String, @age : Int32)
  end
end

Person.new("John", 32).inspect # => #<Person:0x10fd31f20 @name="John", @age=32>

class Person
  def initialize(@name : String, @age : Int32)
  end
end

Person.new("John", 32).to_s # => #<Person:0x10a199f20>