Actors

March’s concurrency model is built on actors and tasks. Actors are isolated processes that communicate exclusively through message passing: no shared mutable state. Tasks are lightweight one-off computations that run concurrently and return a value.

Compiled-actor status: the core actor message plane runs both in the tree-walking interpreter and in ahead-of-time-compiled (native) binaries. In the compiled runtime, both actors and tasks run on an M:N green-thread scheduler (runtime/march_scheduler.c): multiple OS threads, each running many lightweight green threads, with work-stealing across threads. Actor declarations lower to TIR (lib/tir/lower_actor.ml) and emit LLVM IR that calls the public C API (march_spawn/march_send/march_kill/march_is_alive, runtime/march_runtime.c); each actor runs as its own green thread. Actors park cooperatively when their mailbox is empty; tasks park when awaiting a result.

What matches exactly interpreted vs compiled, and what does NOT. The live-message plane (spawn / send (to a live actor) / receive / run_until_idle / is_alive / kill) produces identical observable output on both backends for a program with output that does not depend on scheduler interleaving; this is mechanically pinned by the golden conformance corpus (specs/lang/golden/g35–g37, verified MATCH interpreted-vs-compiled; see the operational reference §4.10.5). The Actor.call plane is also backend-identical as of 2026-07-13: both backends tag-route the zero-arg sentinel positionally to the handler at its ctor index, and both enforce timeout_ms (compiled via a deadline-bounded park in march_actor_call, runtime/march_runtime.c; timeout_ms <= 0 means wait indefinitely); pinned by test/native/actor_counter and test/native/actor_call_timeout. The two formerly-diverging planes are also backend-identical now (their historical findings are closed in the specs/todos/ ledger):

• Capabilities / dead-send (get_cap, send_checked, revoke_cap, is_cap_valid, plain send to a dead pid): an exact byte match as of 2026-07-18: compiled get_cap builds the real epoch cap (niche None for a dead/unknown pid), send_checked/revoke_cap return the same :ok/:error atoms as the interpreter, and send to a dead pid returns None on both backends. Until 2026-09-22 compiled is_cap_valid/send_checked on a cap whose actor had been killed intermittently answered true/:ok (about one run in five), because they read the actor record after it had been freed; fixed, and test/native/cap_epoch_plane now runs the program 51 times per test run so a flake of that shape fails. See core-march.md §4.10.6.
• Supervision / external state inspection: get_actor_field/pid_of_int and the full compiled supervision plane (spawn-time child init, crash isolation, all three restart strategies) work compiled as of 2026-07-08 (examples/supervision_strategies.march runs clean). See core-march.md §4.10.7.

The rest of this tutorial marks each interp-only surface where it appears. For the typing side (actor declaration, spawn/Pid typing, message-payload typing) see the typing reference §2.6; for the scheduler and lowering internals, see the implementation reference (specs/impl/index.md).

Defining an Actor

An actor declaration has three parts:

• state { ... }: the state record type
• init { ... }: the initial state value
• on Msg(...) do ... end: message handlers, each returning the new state

and, optionally, on_stop do ... end: a terminate callback run on a graceful stop (see Stopping an Actor).

actor Counter do
  state { value : Int }
  init  { value: 0 }

  on Increment(n : Int) do
    { state with value: state.value + n }
  end

  on Decrement(n : Int) do
    { state with value: state.value - n }
  end

  on Reset() do
    { state with value: 0 }
  end
end

Parameterised init

init may take a parameter list, supplied at spawn. Every parameter carries a type annotation, and the parameters are in scope in the init expression only (not in handlers; put what a handler needs into the state):

actor Counter do
  state { value : Int, label : String }
  init(start : Int, label : String) { value: start, label: label }

  on Increment(n : Int) do
    { state with value: state.value + n }
  end
end

fn main() do
  let c = spawn(Counter, 41, "answer")   -- start = 41, label = "answer"
  send(c, Increment(1))
end

spawn(Counter, 41, "answer") checks each argument against the matching parameter. Supplying the wrong number of arguments is an error that names the actor’s init signature; spawn(Counter) on an actor whose init takes parameters is rejected, as is spawn(Plain, 1) on an actor whose init takes none. init() is the zero-parameter spelling of the bare init { ... } form. The design rationale is decision D24 of the distributed-deploys plan: an actor that needs a value to start with (a database handle, an Env of capabilities) receives it as a value at spawn time, rather than as a first message that would leave the actor with an “uninitialised” state every handler has to cope with.

A supervised child can be given its init arguments in the supervisor’s supervise block, and a restart re-supplies them; see Supervision.

Inside a handler, state refers to the current state record. Each handler must return the new state (same type as state). The typechecker enforces exactly this: the init block must produce the declared state record, and every handler body is checked to return the state type; see the typing reference §2.6.1 for the precise checks the actor declaration performs (state-record construction, duplicate-handler rejection, message-constructor registration, init/handler conformance).

Spawning Actors

spawn creates a new actor and returns its process identifier (Pid):

fn main() do
  let counter = spawn(Counter)
  -- counter : Pid
end

spawn(Name) requires a literal actor name written directly; a computed actor expression (from an if, match, or function call) is rejected at compile time, because March resolves which actor to spawn statically from its name. The typing account (including the subtlety that the resulting Pid’s type parameter is a fresh variable, not the actor’s state type) is in the typing reference §2.6.2–§2.6.3; the runtime side (registering an actor_inst, returning a VPid) is in core-march.md §4.10.1.

Sending Messages

send delivers a message to an actor asynchronously:

send(counter, Increment(10))
send(counter, Increment(5))
send(counter, Reset())

The message is the constructor applied to its arguments. The actor handles it according to its on clause.

A linear value moves on send, and everything else is immutable or copy-on-write, so there is nothing a message may not carry. A RingBuf is always_linear: putting one in a message is its one consuming use, the sender cannot touch it afterwards, and the receiver is its sole owner (the same for spawn(Recent, rb)). A native array (NativeIntArr and the other NativeArray backing types) is a copy-on-write value: the first write to a shared array copies it, so the sender and the actor each see only their own writes. Ordinary data is immutable. Until 2026-10-06 these six types sat in a non_sendable_types denylist that rejected them in message payloads; that list is empty now and stays in lib/typecheck/typecheck_exhaustive.ml only as the enforcement point for the rule in memory-model.md: a builtin type that writes memory another reference could observe must be linear or copy-on-write before it may exist at all. (The check still runs at the moment a message constructor is applied, for any future entry; see the ci_is_actor_msg field in typecheck.ml’s ctor_info.)

let rb = RingBuf.make(8)
send(worker, Take(rb))     -- consumes rb; the worker now owns the buffer

Message names share one flat global constructor namespace. A handler on Msg(…) registers Msg as an ordinary constructor; there is no per-actor message namespace, exactly analogous to the no-per-module-type-namespace design point (§2.5). So a message name that collides with a constructor another type (including a stdlib type) already declares is ambiguous: writing send(counter, Ping(…)) when the stdlib also declares a Ping constructor is rejected (Constructor \Ping` is defined by multiple types … Use a qualified form to disambiguate). Pick message names unlikely to collide (e.g. Increment, Poke), or qualify. Two consequences of this design (the compiled wrong-actor-send` misroute and the payload-typing rule) are documented in the typing reference §2.6.4.

An actor declared in a nested module is spawned and messaged from the parent by qualified name, the way a nested variant’s constructors are:

mod Inner do
  actor Box do
    state { n : Int }
    init  { n: 0 }
    on Set(k : Int) do { n: k } end
  end
end

fn main(...) do
  let p = spawn(Inner.Box)
  send(p, Inner.Set(1))               -- qualified: resolves
  let m : Inner.Box.Msg = Inner.Set(2)
  send(p, m)
end

The bare Set is visible only inside Inner. It is not exported to the parent, so the parent’s own bare constructors of the same name keep their meaning.

send returns Some(()) if the actor is alive, or None if the actor is dead, on both backends alike (fixed 2026-07-18; see the compiled-actor status note above):

match send(counter, Increment(1)) do
  Some(_) -> println("message delivered")
  None    -> println("actor is dead")
end

See §4.10.2 in core-march.md for the async-enqueue operational rule.

Receiving Messages Inside a Handler

receive() blocks until the next message arrives in the actor’s mailbox. Use it when a handler needs to wait for a sub-message before continuing:

Every message you send (including the follow-up a handler receive()s) must be a declared handler message: the Followup message below is a valid constructor only because the actor declares an on Followup(n) handler. (A message name with no matching handler is not a registered constructor and is rejected at compile time.)

actor Dispatcher do
  state { got : Int }
  init  { got: 0 }

  on Dispatch() do
    -- wait for the follow-up message already queued behind this one
    let follow = receive()
    match follow do
      Followup(n) -> { got: n }
      _           -> state
    end
  end

  on Followup(n : Int) do
    { got: n }
  end
end

fn main() do
  let pid = spawn(Dispatcher)
  send(pid, Dispatch())
  send(pid, Followup(99))   -- queued before Dispatch() is dispatched
  run_until_idle()
end

Blocking semantics: If the mailbox is empty when receive() is called, the actor parks (interpreter: re-queues the triggering message and retries the handler on a later pass; compiled: green thread parks). It resumes automatically once a message is delivered. run_until_idle() returns as soon as all actors are either idle or waiting: no deadlock. See core-march.md §4.10.3 for the pop-or-BlockedOnReceive rule.

Once-per-handler limitation: only the first receive() in a handler body is safe to block on: if a handler calls receive() twice and the second one blocks (empty mailbox), the message the first receive() already popped is lost (the scheduler’s re-queue only restores the outer triggering message). A handler needing multiple messages should recurse, with each receive() the first operation in its own handler body. The example above receive()s exactly once, on an already-queued message, so it neither blocks nor trips this limitation. (This is what the golden witness g36_actor_receive pins.)

Messages are always delivered in FIFO order, so receive() pops the oldest queued message.

Stash and Become: multi-step protocols without selective receive

receive() always pops the oldest message, and only the first receive() in a handler may block, so there is no way to say “wait for this particular message next” (Erlang’s selective receive). What an actor does have is its own state, and that is enough for the two jobs selective receive is used for, the same way Akka’s stash/become cover them:

• become: a mode field that the handlers dispatch on;
• stash: a list in state holding the work that cannot be served yet, replayed through the same serving code when the mode changes.

A session that must be told it is connected before it may serve queries:

type Mode = Connecting | Ready

actor Session do
  state { mode : Mode, stash : List(String), served : String }
  init  { mode: Connecting, stash: Nil, served: "" }

  on Query(q : String) do
    match state.mode do
      Ready      -> serve(state, q)
      Connecting -> { state with stash: Cons(q, state.stash) }   -- stash it
    end
  end

  on Connected() do
    -- become Ready, then unstash: the stash is newest-first, so reverse it
    -- and push each stashed query through the same serving code.
    let ready = { state with mode: Ready, stash: Nil }
    List.fold_left(List.reverse(state.stash), ready, fn (st, q) -> serve(st, q))
  end
end

fn serve(st, q) do
  { mode: st.mode, stash: st.stash, served: st.served ++ q ++ ";" }
end

Sending Query("a"), Query("b"), Connected(), Query("c") serves a;b;c;: the stash drains in arrival order before anything queued behind the transition is looked at. Draining inline is what gives that order. The other unstash shape, re-sending each stashed message to self(), is simpler when the stashed thing really is a whole message, but a re-sent message lands behind whatever is already queued, so here it would serve c;a;b;. Pick by whether arrival order matters to the protocol.

The full example is test/native/actor_stash_become.march, run on both backends.

Checking if an Actor is Alive

let alive = is_alive(counter)
println("alive: " ++ bool_to_string(alive))

Stopping an Actor

kill(counter)

After kill, is_alive(counter) returns false and further sends return None, on both backends. is_alive is a pure registry lookup and is the one lifecycle observation that is an exact byte match interpreted vs compiled (the golden witness g37_actor_lifecycle pins spawn → is_alive true → kill → is_alive false). The operational rules for kill/is_alive are in core-march.md §4.10.6.

Graceful stop: Actor.stop

kill is immediate and drops whatever is queued. Actor.stop(pid, timeout_ms) is the lossless form: the actor accepts no new messages (a send to it returns None), works off the messages already queued, and then dies a Normal death, which no restart type restarts. stop is synchronous: it returns once the actor is dead, or once timeout_ms has passed and the actor has been killed. A negative timeout waits indefinitely; 0 discards the queue as soon as the in-flight handler returns. It returns false for an actor that was already dead or already stopping.

Stopping a supervisor stops its children first, in reverse declaration order, each with its own shutdown budget from the child spec (W w shutdown 5000, shutdown infinity, shutdown brutal; default 5 seconds), and detaches each child before stopping it so the teardown runs no restart strategy.

An actor may stop itself from a handler (Actor.stop(self, 1000)): the handler finishes, its returned state is installed, the rest of the queue drains, and the actor dies.

on_stop: the terminate callback

An actor can run code of its own at shutdown (flush a buffer, checkpoint state, hand unfinished work back to a queue) by declaring one on_stop block among its handlers:

type StoreState = { saved : Int }   -- the Store actor's state record

actor Batcher do
  state { buf : List(String), store : Option(Pid(StoreState)) }
  init  { buf: [], store: None }

  on UseStore(s : Pid(StoreState)) do
    { state with store: Some(s) }
  end

  on Append(s : String) do
    { state with buf: Cons(s, state.buf) }
  end

  -- Hand whatever was batched to the store before dying.
  on_stop do
    match state.store do
      Some(store) -> send(store, Save(List.reverse(state.buf)))
      None        -> None
    end
  end
end

The Store’s Pid arrives in a message and is kept in state: a handler has no capability in scope, so it cannot look an actor up by name with Actor.whereis, which takes a Cap(Actor.Introspect).

Inside on_stop, state is the final state (after the drain) and self is the actor’s own Pid, exactly as in a handler; there are no message parameters, and the block’s value is discarded (a dying actor has no next state). The semantics follow OTP’s terminate/2:

1. It runs on a graceful stop: Actor.stop on the actor, a self-stop, or its supervisor’s teardown with a non-brutal shutdown. It runs on the actor’s own thread, after the drain and before the Normal death, so it has finished by the time Actor.stop returns.
2. It may send messages, and may block on a reply (Actor.call), within the budget below. The actor itself is draining, so messages sent to it are refused.
3. A failure inside it is logged and the shutdown continues. A panic in on_stop prints march: actor on_stop callback failed (the actor still stops): panic: ... to stderr and the actor dies Normal as if on_stop had returned: it is not a crash, so no supervisor restarts it, and a tree teardown proceeds to the next child.
4. It does not run on the brutal path. kill(pid), a crash, and a child spec’s shutdown brutal end the actor without running it. That is what brutal means.
5. It is bounded by the stop timeout. The timeout_ms of Actor.stop (or the child spec’s shutdown budget) covers the drain and on_stop together; if on_stop has not finished when it runs out, the actor is killed there. A stop whose deadline has already passed after the drain skips on_stop entirely.

Both backends implement the same rules, and each is pinned compiled and interpreted by test/native/actor_on_stop*.march. Limits to know:

• A self-stop has no outside waiter to enforce the deadline, so it bounds the drain but cannot cut a blocked on_stop short.
• The interpreter cannot preempt running code, so there the deadline binds only an on_stop that blocks (a receive() it cannot satisfy waits out the deadline and the actor is killed); a compute loop in on_stop runs to completion.
• Under --hot-reload, the callback registered is the one from the code the actor was spawned with; draining across a reload is still open (specs/todos/2026-08-12-graceful-shutdown-and-drain.md).

Monitoring Actor Death

monitor(watcher, target) delivers a control-plane Down(ref, target_pid, reason) message to watcher when target terminates. The local reasons are Normal, Killed, and Crash(message). Match the three fields in a handler rather than treating a monitor as a count of dead actors:

actor Watcher do
  state { seen : Int }
  init  { seen: 0 }

  on CheckDown() do
    match receive() do
      Down(_, target, Normal) ->
        println("stopped " ++ to_string(target))
        state
      Down(_, target, Killed) ->
        println("killed " ++ to_string(target))
        state
      Down(_, _, Crash(error)) ->
        println("crashed " ++ error)
        state
      _ ->
        println("unexpected monitor message")
        state
    end
  end
end

Monitor Down messages are control-plane delivery: they bypass the target watcher’s mailbox limit, so a full bounded mailbox cannot lose the death notification. Local monitoring has the same payload and reason vocabulary on the interpreted and compiled backends; the distributed monitor protocol uses the same Down(ref, target_pid, reason) shape (and additionally has NodeDown).

Why there are no links

March’s fault model is monitors plus supervisors, not BEAM’s links and exit signals. A monitor is one-directional and observational: the watcher receives Down(ref, pid, reason) where the reason is Normal, Killed, or Crash(msg), and determines for itself what to do. Failure propagates downward through supervision trees, never sideways between actor peers.

This is the same choice Akka made in dropping links for DeathWatch plus supervision strategies. A reason-carrying Down gives a watcher everything a link’s exit signal would have told it, without the bidirectional coupling, and without needing a trap_exit escape hatch to make that coupling survivable.

One asymmetric edge remains: task_spawn_link links a plain task to an actor, and if the task’s thunk raises, the linked actor is crashed: a task-to-actor propagation path, not an actor-to-actor one. It is a narrower primitive than a BEAM link (a task cannot itself be linked to or crashed by anything), so it doesn’t reopen the sideways-coupling problem this section argues against.

Named Actors

A Pid is not stable. When a supervisor restarts a crashed child, the replacement gets a new Pid, and everyone still holding the old one is talking to a corpse. The named registry hands out a stable string name instead:

mod Main do
  needs IO

  actor Counter do
    state { n : Int }
    init  { n: 0 }
    on Bump() do { n: state.n + 1 } end
  end

  fn main(io : Cap(IO)) do
    let c = Actor.introspect(io)
    let pid = spawn(Counter)
    println("registered: " ++ bool_to_string(Actor.register(pid, "counter")))
    println("names: " ++ int_to_string(List.length(Actor.registered(c))))

    -- Resolve the name once, then reuse the Pid for the whole burst.
    match Actor.whereis(c, "counter") do
      None -> println("counter is unavailable right now — retry")
      Some(here) ->
        let _ = send(here, Bump())
        let _ = send(here, Bump())
        println("sent")
    end

    println("unregistered: " ++ bool_to_string(Actor.unregister("counter")))
  end
end

A name is released automatically when its actor dies, so a name never resolves to a dead Pid and you do not have to unregister from a crash path.

Introspection is a capability

A Pid is an unforgeable reference: code that was never handed one cannot message the actor behind it. Four operations would break that, since each turns something anyone can write down (an integer, a name, nothing at all) into a Pid: Actor.pid_from_int, Actor.whereis, Actor.list and Actor.registered. They take a Cap(Actor.Introspect), a proof capability that only Actor.introspect(io : Cap(IO)) mints. Mint it once in main, which holds the root capability, and forward it to the code that needs it:

mod Main do
  needs IO
  needs Actor.Introspect

  fn child_of(c : Cap(Actor.Introspect), sup, field : String) do
    match get_actor_field(sup, field) do
      Some(n) -> Actor.pid_from_int(c, n)
      None    -> Actor.pid_from_int(c, -1)
    end
  end

  fn main(io : Cap(IO)) do
    let c = Actor.introspect(io)
    let sup = spawn(Sup)
    send(child_of(c, sup, "worker"), Work())
  end
end

A function that forwards the cap through its signature declares needs Actor.Introspect, as with any proof capability declared elsewhere. Actor.register and Actor.unregister stay unprivileged: registering a Pid you hold is not authority; resolving a name you were never handed is. The raw builtins behind these wrappers (pid_of_int, actor_pid_indices, actor_whereis, actor_registered) are internal to the standard library; a program that calls one is rejected at typecheck time with the wrapper to use:

`pid_of_int` is internal to the standard library; use `Actor.pid_from_int(cap, n)` (see `Actor.introspect`)

Because Actor.introspect takes Cap(IO), a role body or hook under a narrower grant (say Cap(IO.NetConnect)) cannot mint the cap itself; the composition root does, and hands it down. Cross-node references (GlobalPid.make, GlobalRegistry.lookup) are not covered: unforgeability is a process property first.

whereis returns an Option because a name can be momentarily unresolvable. While a supervised child is being respawned (in particular while it waits out its restart backoff) the old actor is gone and its replacement does not exist yet. None there is the accurate signal that the service is mid-restart, not that the name was never registered; retry rather than treating it as a permanent error.

Names survive supervisor restarts, on both backends: the crashing child’s names are brought forward and re-established on its replacement, so a holder outside the supervision tree keeps reaching whichever incarnation is current without at any point learning the new Pid. Hold names, not Pids, across a restart boundary. This includes a live sibling killed by a one_for_all / rest_for_one batch restart, not only the child that actually crashed. If a different live actor claims the name during the restart window, the carried-forward registration is dropped for that name rather than stolen back. Unsupervised actors are unaffected; their names are simply dropped on death.

On a hot path, resolve a name once and cache the Pid instead of calling whereis per message. Concurrent lookups of the same name all bump the refcount on the one stored value, and that contention, not the registry’s table lock, is what bounds same-name resolution; send itself takes no registry lock. Re-resolve when a send fails or a monitor fires, not on every message.

Capability-Based Messaging

For supervision-safe message delivery, use capabilities (Cap). A capability encodes the actor’s identity and current epoch: it becomes stale (and is rejected) if the actor restarts:

-- Obtain a capability for a live actor
match get_cap(pid) do
  None      -> println("actor is dead")
  Some(cap) ->
    -- send_checked validates the epoch before delivering
    match send_checked(cap, Increment(1)) do
      :ok    -> println("delivered")
      :error -> println("actor dead or cap stale")
    end
end

Use capabilities when you hold a reference across an actor restart boundary and need to know whether the message was delivered to the current incarnation of the actor. Under a supervisor, a restarted actor gets a fresh epoch, invalidating caps from before the restart.

The epoch-Cap validation plane is an exact match on both backends as of 2026-07-18: compiled get_cap gates on liveness (niche None for a dead/unknown pid) and compiled send_checked returns the same :ok/:error atoms as the interpreter after checking revocation, epoch match, and liveness (march_send_checked/march_get_cap, runtime/march_runtime.c); pinned by test/native/cap_epoch_plane. A cap holds no reference on its actor, so both calls validate against the actor’s runtime metadata (its terminal flag and epoch), never the actor record itself, and send_checked returns :ok only when the underlying send actually accepted the message (an actor that dies or starts draining between the check and the enqueue gives :error). Before 2026-09-22 the compiled backend read the record’s alive word after the record could already be freed and reused, so a cap on a killed actor intermittently validated. revoke_cap and is_cap_valid are registered in the typechecker (lib/typecheck/typecheck_builtins.ml) and surface-callable on both backends. See core-march.md §4.10.6 for the full epoch-invalidation model.

Synchronous Request-Reply via Actor.call

The Actor module provides a synchronous call pattern. You pass a zero-arg sentinel constructor as the call message; its tag selects which handler receives the call, and the runtime injects the caller (the reply channel) as that handler’s first argument. The handler answers with Actor.reply:

type GetReq = GetReq          -- zero-arg sentinel for the sync call

actor Counter do
  state { count : Int }
  init  { count: 0 }

  -- First handler (tag 0) = the call handler; reply_to is the caller.
  on GetCount(reply_to) do
    Actor.reply(reply_to, state.count)
    state
  end

  on Inc(n : Int) do
    { state with count: state.count + n }
  end
end

fn main() do
  let pid = spawn(Counter)
  Actor.cast(pid, Inc(1))
  run_until_idle()
  match Actor.call(pid, GetReq, 5000) do
    Ok(n)  -> println("count = " ++ int_to_string(n))
    Err(e) -> println("error: " ++ e)
  end
end

This program prints count = 1 on both backends. Actor.call(pid, sentinel, timeout_ms) reads the tag from the zero-arg sentinel, builds an augmented message (same tag, with the caller in field 0), and routes it to the handler at that tag. That handler receives the caller as its first argument and must call Actor.reply(reply_to, result) to unblock the caller. Actor.call returns Ok(result), or Err(reason) if no reply arrives before timeout_ms (a value <= 0 means wait indefinitely).

Two consequences of the tag-selects-the-handler rule:

• The call handler must be declared FIRST in the actor, so it sits at tag 0: the sentinel GetReq has tag 0, and that is the handler the call routes to.
• The sentinel must have a name distinct from the handler (GetReq vs GetCount) to avoid a constructor-name clash.

There is no Call wrapper constructor, and the call handler takes exactly one argument (the reply channel).

Calling from inside a handler. A handler may itself Actor.call another actor. While it waits, the calling actor handles nothing else: messages sent to it in the meantime stay in its mailbox, in arrival order, and are handled after the current handler returns. Only the reply ends the wait (both backends; pinned by test/native/actor_call_in_handler_keeps_messages).

Two notes (both resolved 2026-07-13). (1) timeout_ms is enforced in the compiled runtime via a deadline-bounded park (march_actor_call, runtime/march_runtime.c); the caller’s green thread parks on the scheduler rather than busy-polling, and wakes on reply delivery or at the deadline; a call that never receives a reply returns Err(...) once the deadline passes, and timeout_ms <= 0 means wait indefinitely. Correlation-checked replies (actor-system hardening, task 4): every reply is wrapped in an envelope that stores the correlation id issued for that specific march_actor_call invocation; the receive loop discards any envelope with a correlation id that doesn’t match; a late reply from a timed-out first call can no longer be misdelivered as the answer to a second, unrelated call (march_actor_call_unwrap, runtime/march_runtime.c). (2) The interpreter now dispatches Actor.call identically to the compiled runtime: it tag-routes the zero-arg sentinel to the handler at the same ctor index and binds the caller as the handler’s single argument (lib/eval/eval.ml actor_call). The historical interp-only on Call(ref, msg) two-argument form is retired. Both behaviors are pinned by the test/native/actor_counter and test/native/actor_call_timeout goldens, which pass on both backends.

Historical regression, fixed 2026-07-22: Actor.call’s reply value was briefly corrupted compiled: a scalar reply (e.g. value=5) came back as its raw tagged bit pattern (value=11) instead of the untagged integer. Root cause: int_to_string/ bool_to_string/float_to_string had no dedicated argument-coercion arm in lib/tir/llvm_emit.ml’s EApp emission, so a generically-extracted Result payload flowed into the C call still tagged. Fixed by adding the missing coercion arms (mirroring the existing int_not/bitwise-op pattern); test/native/actor_counter now matches its golden (value=5) on both backends.

Actor.cast(pid, msg) is fire-and-forget: equivalent to send but goes through the Actor module. Both Actor.cast and Actor.call’s message payloads are checked for non-sendable types identically to send; see the note under Sending Messages.

Request-reply by reply address

A lower-level request-reply pattern needs no Actor.call at all: the requester puts its own Pid (from self()) in the message, and the handler replies with a plain send to that address. It is built entirely from send, so it behaves identically on both backends, and it is the right choice when a handler needs to reply to more than one caller, or reply asynchronously outside the call/timeout protocol:

on Ask(question : String, reply_to) do
  send(reply_to, Answer(compute_answer(question)))
  state
end

The requester must itself be an actor: it handles the Answer(...) reply in its own on Answer(...) clause. Actor.call covers the common single-request/single-reply case; reach for this pattern when you need more flexibility than a one-shot call.

A Complete Actor Example

mod ActorDemo do
  needs IO.Console

  actor Counter do
    state { value : Int }
    init  { value: 0 }

    on Increment(n : Int) do
      { state with value: state.value + n }
    end

    on Poke(label : String) do
      println("[Counter] poke from " ++ label
              ++ ", value = " ++ int_to_string(state.value))
      state
    end
  end

  actor Logger do
    state { count : Int }
    init  { count: 0 }

    on Log(msg : String) do
      let n = state.count + 1
      println("[LOG #" ++ int_to_string(n) ++ "] " ++ msg)
      { state with count: n }
    end
  end

  fn main(_c : Cap(IO.Console)) do
    let counter = spawn(Counter)
    let logger  = spawn(Logger)

    send(counter, Increment(10))
    send(logger,  Log("counter incremented by 10"))
    send(counter, Increment(5))
    send(counter, Poke("main"))

    kill(logger)
    println("logger alive: " ++ bool_to_string(is_alive(logger)))

    match send(logger, Log("dropped")) do
      None    -> println("message dropped — actor is dead")
      Some(_) -> ()
    end

    send(counter, Poke("after kill"))
    run_until_idle()
  end

end

(This example uses the message name Poke rather than Ping: Ping collides with a stdlib constructor in the flat global namespace; see the note under Sending Messages. Interpreted, it prints logger alive: false, message dropped — actor is dead, then [Counter] poke from main, value = 15 and [Counter] poke from after kill, value = 15. It uses only the live-message + kill/is_alive plane, so compiled output is an exact byte match.)

Actor State with Records

Complex state uses record types. Functional update with { state with field: new_value } is the canonical way to update state:

actor WebServer do
  state {
    request_count : Int,
    error_count   : Int,
    last_path     : String
  }
  init {
    request_count: 0,
    error_count:   0,
    last_path:     ""
  }

  on Req(path : String, status : Int) do
    let rc = state.request_count + 1
    let ec = if status >= 400 do state.error_count + 1 else state.error_count end
    { state with
        request_count: rc,
        error_count:   ec,
        last_path:     path }
  end

  on Stats() do
    println("requests: " ++ int_to_string(state.request_count))
    println("errors: "   ++ int_to_string(state.error_count))
    state
  end
end

(This example uses the message name Req rather than Request: Request collides with the stdlib Http.Request constructor in the flat global namespace; see the note under Sending Messages.)

Tasks: Lightweight Concurrent Computations

Tasks are a simpler alternative to actors when you just need to run a function concurrently and collect its result. Use the Task module:

-- Spawn a task and await its result
let t = Task.async(fn () -> expensive_computation())
let result = Task.await(t)   -- Ok(value) or Err(reason)

-- Parallel map
let results = Task.async_stream([1, 2, 3], fn n -> n * n)
-- [Ok(1), Ok(4), Ok(9)]

-- Await multiple tasks
let t1 = Task.async(fn () -> fetch_user(1))
let t2 = Task.async(fn () -> fetch_user(2))
let [r1, r2] = Task.await_many([t1, t2])

-- Unwrap directly (panics on error)
let value = Task.await!(t)

Tasks run on the same M:N green-thread pool as actors. Spawning 250,000+ tasks is routine; the scheduler distributes them across OS threads automatically.

See the Task module docs for the full API including Task.race, Task.any, Task.scope, and Task.all_settled.

To run a transformation over a whole collection in parallel without wiring up tasks by hand, use the data-parallel List operations (pmap, pmap_n, pfilter, preduce); see Parallel Collections.

Running Until Idle

In scripts and tests, run_until_idle() processes all pending actor messages before continuing:

fn main() do
  let counter = spawn(Counter)
  send(counter, Increment(1))
  send(counter, Increment(2))
  send(counter, Increment(3))
  run_until_idle()
  -- All three messages are processed here
  send(counter, Poke("done"))
  run_until_idle()
end

What it guarantees (compiled). run_until_idle() returns only when every other process is quiescent at once:

• none is runnable or running;
• none holds a deliverable message;
• none is parked on a timer wake that is still live;
• no message was sent and no process was spawned while that was being checked.

So a message chain between actors (a ping-pong, a pipeline) runs to its end before run_until_idle() returns. It does not wait for:

• a message scheduled with send_after that has not yet been delivered;
• work in other OS processes or on other nodes.

(Until 2026-09-28 the check was not a consistent snapshot, and a busy ping-pong could return early about once in a hundred runs at 14 schedulers.)

In long-running applications, the scheduler runs automatically; you do not call run_until_idle(). run_until_idle() drains the scheduler to a fixed point (every mailbox empty); its operational rule is in core-march.md §4.10.4, and the determinism property it enables (interleaving-free output, an exact byte match interpreted vs compiled) is §4.10.5.

Actor Identity: self()

Inside a handler, self() returns the current actor’s Pid. Useful for passing yourself as a reply address:

on Request(question : String, caller) do
  let answer = compute_answer(question)
  send(caller, Answer(answer, self()))
  state
end

(As of 2026-07-22, self() typechecks as this actor’s own Pid[state] (the same type spawn produces for it), so is_alive(self()) and a message field explicitly annotated : Pid both unify cleanly; previously self() was registered as plain Int, causing a confusing expected Pid but got Int error. A separate, still-open gap: a bare Pid annotation with no type parameter can resolve against the unrelated GlobalPid.Pid record type sharing the same bare name in the flat global namespace, rather than the parametric actor Pid(a) that spawn/self() actually produce, leaving caller and reply payloads unannotated, as above, still sidesteps that one.)

App Entry Point

For long-running applications, use app instead of (or alongside) main:

mod MyService do
  actor Worker do
    state { count : Int }
    init  { count: 0 }
    on Tick() do { state with count: state.count + 1 } end
  end

  app MyService do
    Supervisor.spec(:one_for_one, [worker(Worker)])
  end
end

The app declaration integrates with the supervision system. See Supervision for the tutorial, and core-march.md §4.10.7 for the operational rules of restart and epoch invalidation.

How this relates to the supervise block. These are two spellings of the same idea. The supervise do strategy one_for_one … Child field end block you put inside an ordinary actor (see Supervision) declares that actor’s supervised children with a small DSL. An app body instead evaluates to a Supervisor.Spec value: Supervisor.spec(:one_for_one, [worker(Worker), …]) is the value-level counterpart of that block, and it defines the application’s single top-level supervisor. The two surfaces spell the strategy differently: a bare one_for_one in the supervise block versus the atom :one_for_one passed to Supervisor.spec. Reach for supervise to give an actor children; reach for app to declare the root of a long-running application. The app / Supervisor.spec / worker DSL is interpreter-only (see App-Level Entry Point); compiled programs use supervise.

Supervision observation is an exact match on both backends as of 2026-07-08: the compiled supervisor runs each declared child’s init at spawn(Sup), and get_actor_field(sup, …)

• Actor.pid_from_int(c, …) (the surface way to read a supervised child’s pid out of the supervisor state; c is the Cap(Actor.Introspect) minted by Actor.introspect) resolve correctly compiled (a real shape-registry lookup and a safe dead-actor fallback, respectively, in runtime/march_extras.c/runtime/march_runtime.c; no longer stubs). examples/supervision_strategies.march runs clean (exit 0) compiled, exercising all three restart strategies (one_for_one/one_for_all/rest_for_one).

Choosing a concurrency primitive

March gives you several concurrency tools, and they all run on the same M:N green-thread scheduler; the choice is about shape of problem, not about performance tiers. One mental model to keep them straight:

Actors = identity + state + mailbox. Tasks = structured fork/join. Flow = bounded streaming. pmap = data-parallel collections. Session channels = a typed two-party conversation.

Pick by what you need:

Rules of thumb:

• Default to Task.async / await_many for “do these N things concurrently, give me the answers.” It’s the simplest structured option.
• Default to an actor the moment there’s mutable state with an identity: something that several callers update over time.
• Choose Flow over an unbounded Task.async_stream when a fast producer could overwhelm a slow downstream stage and pile up in-flight work. See Flow & Backpressure.
• Choose pmap over hand-wired tasks when the input is a list, items are independent, and you want the order-preserving, threshold-managed convenience. See Parallel Collections.
• Choose session channels over a bare actor when two parties run a fixed protocol and ordering correctness matters. See Session Types.

Mailbox Limits and Backpressure

By default an actor’s mailbox is unbounded; a producer that outruns its consumer grows the mailbox without limit. Actor.set_queue_limit(pid, limit, policy) bounds it:

Actor.set_queue_limit(pid, 1000, 3)   -- cap at 1000, block_sender policy

Or declare the bound with the actor, so every spawn gets it and no caller has to remember the call:

actor Worker do
  state { n : Int }
  init  { n: 0 }
  mailbox 1000 drop_old        -- after init, before any supervise block
  on Work() do ... end
end

mailbox N policy takes the policy by name — drop_new, drop_old or block_sender — and lowers to Actor.set_queue_limit(pid, N, policy) right after each spawn(Worker). block_sender is compiled-only there too: under the interpreter the spawn fails with the same message the call does.

policy is one of:

Dropped messages (policies 1/2) are counted in Scheduler.dropped_messages(). The interpreter’s single-threaded eager scheduler cannot park a sender without deadlocking, so it does not implement policy 3: Actor.set_queue_limit(pid, n, 3) and a mailbox N block_sender declaration both fail under the interpreter with an error naming the alternatives, rather than silently running unbounded (lib/eval/eval_builtins.ml, actor_set_mailbox_limit; resolved 2026-09-14).

Under a drop policy, a dropped Actor.call request or its reply is impossible to tell from a lost reply at the caller; both surface as a timeout Err from Actor.call. Callers that rely on Actor.call against a bounded actor should prefer the block_sender policy (3) instead, so no request or reply is silently dropped at any point.

Scheduler Observability

The Scheduler module exposes runtime counters for load-shedding decisions: a supervisor or ingress actor can poll them to decide when to shed:

if Scheduler.live_procs() > 10000 do
  println("shedding: too many live actors")
else
  dispatch_work()
end

The interpreted backend reports the subset that’s meaningful without the C scheduler (live actor count); everything else reads 0 on both backends rather than erroring.

Scheduler answers “is the system behind?”. “Which actor is behind?” is Actor.top_by_mailbox(c, n) and Actor.over_mailbox(c, threshold), built on Actor.list(c) and mailbox_size (c from Actor.introspect, see Introspection is a capability): both are snapshots (an actor can die or drain between the walk and your reaction) and cost one pass over every live actor, so poll them from a timer, not a hot path. There is no push-style alarm that fires when a queue crosses a threshold, and no tracing; see specs/todos/2026-08-12-per-actor-introspection-and-alarms.md.

Reading an actor’s state: Actor.inspect_state

Actor.inspect_state(d, pid, timeout_ms) asks a running actor for its state, like Erlang’s sys:get_state. d is a Cap(Actor.Debug), minted from Cap(IO) by Actor.debug(io); it is a separate cap from Actor.Introspect because it reads the actor’s data, not just its counters.

let d = Actor.debug(io)
match Actor.inspect_state(d, counter, 100) do
  Ok(s) -> println(s)            -- { count: 3, tags: [a, b], best: Some(3) }
  Err(InspectTimeout) -> println("busy")
  Err(InspectDead) -> println("gone")
  Err(InspectSelf) -> println("asked itself")
  Err(InspectFailed(why)) -> println(why)
end

The text lists the state fields in declaration order, each printed by its own Show, and is the same on both backends. A field whose type holds functions (or a type variable or session channel) has no Show and prints as <opaque>. The request is answered between messages, skips the mailbox limit (a full mailbox still answers), and does not count as a message in the actor’s counters. It fails without disturbing the actor: InspectTimeout when the actor does not answer in time or is inside a nested receive, InspectDead, InspectSelf (an actor cannot wait on itself), and InspectFailed when a field’s Show panics.

Builtins Reference

Backends: both = an exact byte match interpreted vs compiled. As of 2026-07-18 this covers every builtin below, including the capability and supervision-observation plane that used to diverge or crash compiled (see the compiled-actor status note at the top of this page).

Next Steps

The concurrency and distribution docs form a journey: actors are the foundation; each step below builds on them:

• Supervision Trees: fault-tolerant hierarchies with automatic restart, ending in a capstone crash-tolerant job processor.
• Parallel Collections: pmap / pmap_n for data-parallel work on the same scheduler.
• Flow & Backpressure: bounded streaming pipelines when a fast producer outruns a slow consumer.
• Session Types: typed two-party protocols with a message order the compiler enforces.
• Clustering & RPC: take a supervised actor app from one node to a cluster with cross-node calls.
• Hot Code Reload: deploy new code to a running server without restarting; actors migrate their state on the fly.
• Linear Types: how linear types interact with message passing.
• Task stdlib: full Task API reference.
• Overload & Resilience: the practical guide to mailbox limits, load shedding, deadlines, and restart backoff working together.