class Fiber::ExecutionContext::Isolated

• Fiber::ExecutionContext::Isolated
• Reference
• Object

Overview

Isolated execution context to run a single fiber.

Concurrency and parallelism are disabled. The context guarantees that the fiber will always run on the same system thread until it terminates; the fiber owns the system thread for its whole lifetime.

Keep in mind that the fiber will still run in parallel to other fibers running in other execution contexts at the same time.

Concurrency is disabled, so an isolated fiber can't spawn fibers into the context, but it can spawn fibers into other execution contexts. Since it can be inconvenient to pass an execution context around, calls to ::spawn will spawn a fiber into the specified spawn_context during initialization, which defaults to Fiber::ExecutionContext.default.

Isolated fibers can normally communicate with other fibers running in other execution contexts using Channel, WaitGroup or Mutex for example. They can also execute IO operations or sleep just like any other fiber.

Calls that result in waiting (e.g. sleep, or socket read/write) will block the thread since there are no other fibers to switch to. This in turn allows to call anything that would block the thread without blocking any other fiber.

For example you can start an isolated fiber to run a blocking GUI loop, transparently forward ::spawn to the default context, then keep the main fiber to wait until the GUI application quit:

gtk = Fiber::ExecutionContext::Isolated.new("Gtk") do
  Gtk.main
end
gtk.wait

Included Modules

• Fiber::ExecutionContext
• Fiber::ExecutionContext::Scheduler

Defined in:

Constructors

• .new(name : String, spawn_context : ExecutionContext = ExecutionContext.default, &func : -> )

  Starts a new thread named name to execute func.

Instance Method Summary

• #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
• #running? : Bool
• #spawn(*, name : String | Nil = nil, &block : -> ) : Fiber

  Instantiates a fiber and enqueues it into the scheduler's local queue.

• #status : String

  Returns the current status of the scheduler.

• #to_s(io : IO) : Nil

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

• #wait : Nil

  Blocks the calling fiber until the isolated context fiber terminates.

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>

ctx = Fiber::ExecutionContext::Isolated.new("test") do
  raise "fail"
end
ctx.wait # => re-raises "fail"