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);

}