Packages

skuld_concurrency

0.42.0
0.47.0 0.46.0 0.45.0 0.44.0 0.42.0 0.41.0 0.40.0 0.38.0 0.37.0 0.36.0 0.35.0 0.34.0 0.33.0 0.32.1 0.32.0

Cooperative concurrency for Skuld: FiberPool scheduler, Channel, Brook streaming, Yield, and AsyncCoroutine process bridging.

HexDocs

Current section

Files

Jump to
Readme
15 Versions
1 Dependency
2 Dependants
Files
Activity
skuld_concurrency lib skuld coroutine foreign_suspended.ex
Raw

lib/skuld/coroutine/foreign_suspended.ex 

defmodule Skuld.Coroutine.ForeignSuspended do

  @moduledoc """

  Fiber state when a single fiber suspends on a foreign resource.



  The FiberPool scheduler collects all `ForeignSuspended` fibers, extracts

  their individual `ForeignSuspend` values, and bundles them into a

  `Coroutine.ForeignSuspensions` aggregate to return to the caller.

  """



  alias Skuld.Comp.Env

  alias Skuld.Comp.ForeignSuspend



  @type t :: %__MODULE__{

          id: term(),

          suspend: ForeignSuspend.t(),

          env: Env.t()

        }



  defstruct [:id, :suspend, :env]

end