class Fiber::ExecutionContext::MultiThreaded

• Fiber::ExecutionContext::MultiThreaded
• Reference
• Object

Overview

A multi-threaded execution context which owns one or more threads. It's fully concurrent and fully parallel.

Owns multiple threads and starts a scheduler in each one. The number of threads is dynamic. Setting the minimum and maximum to the same value will start a fixed number of threads.

Fibers running in this context can be resumed by any thread in the context. Fibers can run concurrently and in parallel to each other, in addition to running in parallel to any other fiber running in other contexts.

mt_context = Fiber::ExecutionContext::MultiThreaded.new("worker-threads", 4)

10.times do
  mt_context.spawn do
    do_something
  end
end

sleep

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>