concurrent.d

concurrent.d

import std.stdio;
import std.conv;
import std.concurrency;

void workerFunc() {
    int value = 0;
    value = receiveOnly!int();
    while (value >= 0) {
        writefln("Worker: %s received", value);
        double result = to!double(value) / 5;
        ownerTid.send(result);
        value = receiveOnly!int();
    }
}

void main() {
    Tid worker = spawn(&workerFunc);

    foreach(value; 1 .. 5) {
        worker.send(value);
        double result = receiveOnly!double();
        writefln("sent: %s \nreceived: %s", value, result);
    }

    worker.send(-1);
}