Issue calling methods using std.concurrency

[Ali Çehreli]

On 04/22/2012 07:15 PM, Casey wrote:
> Hello,
>
> I'm getting some errors when I wrap a struct that I've written with
> another struct. Here are the errors I'm getting:
>
> tqueue.d(14): Error: function queue.Queue!(int).Queue.enqueue (int
> value) is not
> callable using argument types (int) shared
> tqueue.d(15): Error: function queue.Queue!(int).Queue.dequeue () is not
> callable
> using argument types ()
>
> Here's the receive block which the issue:
>
> receive(
> (T value) { queue.enqueue(value); },
> (Tid caller) { send(caller, queue.dequeue); }
> );
>
> The queue itself is shared. Outside of that, nothing special going on. I
> just have a class that I want to be able to in a concurrent environment
> without having to modify the original class.
>
> Any thoughts?

This works at least with 2.059 on 64-bit Linux:

import std.stdio;
import std.concurrency;
import core.thread;

class Foo
{
     int i;
}

void workerFunc(Tid owner)
{
     receive(
         (shared(Foo) foo) {
             writeln("Before: ", foo.i);
             foo.i = 42;
         });

     owner.send(42);
}

void main (string[] args)
{
     shared foo = new shared(Foo);

     auto worker = spawn(&workerFunc, thisTid);
     worker.send(foo);
     receiveOnly!int();
     writeln("After: ", foo.i);
}

The output:

Before: 0
After: 42

Ali