On 26/04/2011 19:48, Andrej Mitrovic wrote:
import std.stdio;
import std.concurrency;

void print(int[] a...)
{
     foreach(b; a)
         writeln(b);
}

void main()
{
     int value;
     spawn(&writeln, value);
     spawn(&print, value);
}

Neither of these calls will work. I want to continuously print some values but 
without blocking the thread that issues the call to print, and without using 
locks. Since it's a print function I need it to take a variable number of 
arguments.

How do I go around doing this? Perhaps I could use some kind of global 
Variant[] that is filled with values, and a foreground thread pops each value 
as it comes in and prints it?

Or maybe I should use send()?

I'm looking for something fast which doesn't slow down or pause the work thread.

Multithreading is hard business. :]

Try this:
----
import std.concurrency;
import std.stdio;

void printer()
{
    try
    {
        while(true)
        {
            writeln(receiveOnly!int());
        }
    }
    catch(OwnerTerminated)
    {
    }
}

void main()
{
    auto tid = spawnLinked(&printer);
    send(tid, 2);
    send(tid, 3);
    send(tid, 4);
}
----

--
Robert
http://octarineparrot.com/

Reply via email to