module pind.samples.ja.concurrency.concurrency_14;

/* 警告: このプログラムの実行中は、
 *          システムが応答しなくなる可能性がある。 */
import std.concurrency;
import core.thread;

void workerFunc() {
    while (true) {
        ownerTid.send(42);    // ← メッセージを連続的に表示する
    }
}

void main() {
    spawn(&workerFunc);

    while (true) {
        receive(
            (int message) {
                // 各メッセージに時間を費やす
                Thread.sleep(1.seconds);
            });
    }
}