Threads and OwnerTerminated
    Andrej Mitrovic 
    andrej.mitrovich at gmail.com
       
    Thu Nov 17 11:56:25 PST 2011
    
    
  
This is an example from TDPL:
import std.concurrency;
import std.exception;
import std.stdio;
void main()
{
    auto low = 0;
    auto high = 100;
    auto tid = spawn(&writer);
    foreach (i; low .. high)
    {
        writeln("Main thread: ", i);
        tid.send(thisTid, i);
        enforce(receiveOnly!Tid() == tid);
    }
}
void writer()
{
    for (;;)
    {
        auto msg = receiveOnly!(Tid, int)();
        writeln("Secondary thread: ", msg[1]);
        msg[0].send(thisTid);
    }
}
This will throw an OwnerTerminated exception on exit since the writer
thread calls receiveOnly() after the main thread was killed:
std.concurrency.OwnerTerminated at std\concurrency.d(214): Owner terminated
So what is expected here, am I always supposed to wrap receive() in a try/catch?
Btw, is std.concurrency planned to be expanded/improved upon? Or is
this a low-level portable messaging API (emphasis on messaging,
core.thread is lower-level), on top of which more complex APIs can be
built on?
    
    
More information about the Digitalmars-d-learn
mailing list