fork download

copy

import std.stdio, std.concurrency;
 
void foo()
{
    bool cont = true;
 
    while (cont)
    {
        receive( // delegates are used to match the message type
            (int msg) => writeln("int received: ", msg),
            (Tid sender) { cont = false; sender.send(-1); },
            (Variant v) => writeln("huh?") // Variant matches any type
        );
    }
}
 
void main()
{
    auto tid = spawn(&foo); // spawn a new thread running foo()
 
    foreach (i; 0 .. 10)
        tid.send(i);   // send some integers
    tid.send(1.0f);    // send a float
    tid.send("hello"); // send a string
    tid.send(thisTid); // send a struct (Tid)
 
    receive((int x) => writeln("Main thread received message: ", x));
}

prog.d(10): found 'msg' when expecting '.' following 'int'
prog.d(10): found ')' when expecting identifier following 'int.'
prog.d(10): expression expected, not '>'
prog.d(10): found 'writeln' when expecting ')'
prog.d(12): found 'v' when expecting ')'
prog.d(12): expression expected, not '>'
prog.d(12): found 'writeln' when expecting ';' following 'statement'
prog.d(13): found ')' when expecting ';' following 'statement'
prog.d(27): found 'x' when expecting '.' following 'int'
prog.d(27): found ')' when expecting identifier following 'int.'
prog.d(27): expression expected, not '>'
prog.d(27): found 'writeln' when expecting ')'

Standard output is empty