Channels are the primary message-passing mechanism in Nyx. channel_new(capacity) creates a buffered channel, channel_send pushes a value, and channel_recv blocks until a value is available. Channels are declared as Map type.
// Channels — typed message passing between threads // Canales — paso de mensajes tipado entre hilos var ch: Map = Map.new() fn producer() -> int { var i: int = 0 while i < 5 { channel_send(ch, i) i = i + 1 } // Send sentinel to signal done channel_send(ch, -1) return 0 } fn main() -> int { // Create a buffered channel (capacity 10) ch = channel_new(10) // Spawn producer thread let h: int = thread_spawn(producer) // Receive messages until sentinel var running: bool = true while running { let val: int = channel_recv(ch) if val == -1 { running = false } else { print("received: " + int_to_string(val)) } } thread_join(h) channel_destroy(ch) print("done") return 0 }
received: 0 received: 1 received: 2 received: 3 received: 4 done
How it works
Channels in Nyx use the Map type as their declaration type -- this is a key detail to remember. channel_new(10) creates a buffered channel that can hold up to 10 values before a sender blocks.
The producer sends integers 0 through 4, then sends -1 as a sentinel value to signal completion. The main thread loops calling channel_recv, which blocks until data is available, and stops when it receives the sentinel.
Always call channel_destroy after both sender and receiver are done to free the underlying resources. The thread_join call ensures the producer has finished before cleanup.