actors library?

[Timon Gehr]

On 01/24/2012 07:51 PM, xancorreu wrote:
> Al 24/01/12 13:37, En/na Dejan Lekic ha escrit:
>> Xan, read this article please:
>> http://www.informit.com/articles/article.aspx?p=1609144
>>
>> You have exactly what you are looking for in the D runtime and
>> standard library.
> I read it and **after** I post the question. I don't know how
> std.concurrency is related to actors model. Can you enlight me?
>
> Thanks,
> Xan.

std.concurrency is an implementation of the actor model.
'Actor model' does not imply 'Object Oriented'.

Example 1:

import std.stdio, std.concurrency;
void myActor() {
     try {
         for(;;){
             receive(
                 (int i){ writeln("Received integer: ",i); }
             );
         }
     }catch(Exception e){
         // cleanup
     }
}

void main() {
     auto actor = spawn(&myActor);
     foreach(i;0..10) actor.send(i);
}

Example 2:

import std.stdio, std.concurrency;
import core.thread;
alias Thread.sleep sleep;
void ping() {
     Tid pong;
     try {
         for(;;){
             receive(
                 (string s){
                     writeln("ping received ",s);
                     sleep(dur!"seconds"(1));
                     pong.send("ping");
                 },
                 (Tid newPong){ pong = newPong; }
             );
         }
     }catch(Exception e){}
}

void pong(Tid ping) {
     try {
         ping.send("pong");
         for(;;){
             receive(
                 (string s){
                     writeln("pong received ",s);
                     sleep(dur!"seconds"(1));
                     ping.send("pong");
                 }
             );
         }
     }catch(Exception e){}
}

void main() {
     auto a1 = spawn(&ping);
     auto a2 = spawn(&pong,a1);
     a1.send(a2);
     sleep(dur!"seconds"(10));
}