xxxxxxxxxx
import std;
import core.thread;
import core.time;
void worker()
{
while (true)
{
immutable shouldExit = receiveTimeout((-1).seconds,
(OwnerTerminated o) {}
);
if (shouldExit)
{
writeln("Exiting");
return;
}
// Do work...
writeln("working");
Thread.sleep(1.seconds);
}
}
void main()
{
spawn(&worker);
Thread.sleep(3.seconds);
}