sigildocs

(sigil async)

(sigil async) - Cooperative Async Runtime

Provides a cooperative multitasking runtime with lightweight tasks, async I/O, and timer support. Tasks yield control explicitly via blocking operations (sleep, I/O waits, channel operations).

Basic Usage

(import (sigil async))

(with-async
  (go (begin
        (display "Task A\n")
        (sleep 0.1)
        (display "Task A done\n")))
  (go (begin
        (display "Task B\n")
        (sleep 0.05)
        (display "Task B done\n"))))

I/O Integration

(with-async
  (go (begin
        (await-readable sock)
        (display (socket-read sock)))))

Exports

schedulerprocedure

Scheduler record type.

The scheduler manages concurrent tasks with support for I/O and timer-based waiting.

scheduler?procedure

Test if a value is a scheduler struct.

scheduler-run-queueprocedure

Get the run-queue field of a scheduler struct.

scheduler-blocked-countprocedure

Get the blocked-count field of a scheduler struct.

scheduler-task-countprocedure

Get the task-count field of a scheduler struct.

scheduler-io-waitersprocedure

Get the io-waiters field of a scheduler struct.

scheduler-fd-waitersprocedure

Get the fd-waiters field of a scheduler struct.

scheduler-timer-waitersprocedure

Get the timer-waiters field of a scheduler struct.

set-scheduler-run-queue!procedure

Set the run-queue field of a scheduler struct.

set-scheduler-blocked-count!procedure

Set the blocked-count field of a scheduler struct.

set-scheduler-task-count!procedure

Set the task-count field of a scheduler struct.

set-scheduler-io-waiters!procedure

Set the io-waiters field of a scheduler struct.

set-scheduler-fd-waiters!procedure

Set the fd-waiters field of a scheduler struct.

set-scheduler-timer-waiters!procedure

Set the timer-waiters field of a scheduler struct.

make-schedulerprocedure

Create a new scheduler.

scheduler-spawnprocedure

Add a new task to the scheduler.

scheduler-runprocedure

Run all scheduler tasks until completion or deadlock.

yieldprocedure

Yield control to the scheduler.

Allows other tasks to run before continuing.

await-readableprocedure

Wait until a socket is readable.

Yields to the scheduler until the socket has data available.

await-writableprocedure

Wait until a socket is writable.

Yields to the scheduler until the socket can accept data.

in-async-context?procedure

Check if currently running in an async context.

Returns #t if running inside with-async, #f otherwise. Useful for writing code that behaves differently in sync vs async contexts.

(if (in-async-context?)
    (display "running async\n")
    (display "running sync\n"))
await-readable-fdprocedure

Wait until a file descriptor is readable.

Yields to the scheduler until the fd has data available. Use for non-blocking reads from process pipes.

await-writable-fdprocedure

Wait until a file descriptor is writable.

Yields to the scheduler until the fd can accept data. Use for non-blocking writes to process pipes.

current-schedulervariable

(No description)

with-asyncvariable

(No description)

%run-asyncvariable

(No description)

govariable

(No description)

%go-spawnvariable

(No description)

sleepvariable

(No description)

when-asyncvariable

(No description)

if-asyncvariable

(No description)

async-prompt-tagvariable

(No description)

scheduler-enqueue!variable

(No description)

scheduler-dec-blocked!variable

(No description)