std::sync::channel - メッセージパッシング

Go風のバウンデッドチャネルによるスレッド間メッセージパッシング。

対応バックエンド: Native (LLVM) のみ

最終更新: 2026-02-08

基本的な使い方

import std::sync::channel::create;
import std::sync::channel::send;
import std::sync::channel::recv;
import std::sync::channel::close;
import std::sync::channel::destroy;
import std::thread::spawn;
import std::thread::join;
import std::io::println;

long ch;

void* producer(void* arg) {
    for (int i = 0; i < 5; i++) {
        send(ch, i as long);
    }
    close(ch);
    return 0 as void*;
}

int main() {
    ch = create(4);  // バッファサイズ4

    ulong t = spawn(producer as void*);

    // 受信ループ
    long value = 0;
    while (recv(ch, &value) == 0) {
        println("Received: {value}");
    }

    join(t);
    destroy(ch);
    return 0;
}

ノンブロッキング送受信

import std::sync::channel::try_send;
import std::sync::channel::try_recv;

// 送信試行
int result = try_send(ch, 42);
if (result == 0) {
    println("Sent");
} else if (result == -2) {
    println("Buffer full");
}

// 受信試行
long value = 0;
result = try_recv(ch, &value);
if (result == 0) {
    println("Got: {value}");
} else if (result == -2) {
    println("Buffer empty");
}

API一覧

注意事項

• value は long 型です。ポインタを渡す場合はキャストが必要です
• close() 後も残データの recv() は可能です
• destroy() はチャネルのメモリを解放します。使用後は必ず呼んでください

関連: スレッド · Mutex · Atomic