"Spawn as many thousand threads as you like" and D

[Sönke Ludwig via Digitalmars-d]

Am 07.05.2014 19:06, schrieb Sönke Ludwig:
> Am 07.05.2014 17:28, schrieb Bienlein:
>>
>> Hello Sönke,
>>
>> would it be possible in vibe.d to spawn a task the usual actor-style way
>> as it is done with kernel threads in D? What I mean is this:
>>
>> void spawnedFunc(Tid tid)
>> {
>>     receive(
>>       (int i) { writeln("Received the number ", i);}
>>     );
>>
>> }
>>
>> auto tid = spawn(&spawnedFunc, thisTid);
>>
>>
>> Thanks, Bienlein
>
> The Tid handling is currently a little different, but apart from that it
> should work like this:
>
>      import vibe.core.core;
>      import vibe.core.concurrency;
>
>      void spawnedFunc(Tid tid)
>      {
>          receive(
>            (int i) { writeln("Received the number ", i); }
>          );
>      }
>
>      // run it as a fiber in the same thread
>      // note: runTask only takes a delegate to make runTask({ ... })
>      // work without an ambiguity error
>      auto tid = runTask(toDelegate(&spawnedFunc), Task.getThis());
>
>      // or run it in the thread pool instead
>      runWorkerTask(&spawnedFunc, Task.getThis());
>
> Having said that, I'll just add a "thisTid" property to
> vibe.core.concurrency to make that part API compatible. I'd also add a
> "spawn" alias, but the question is if that should point to runTask or
> rather to runWorkerTask.


BTW, a runnable example can be found here:
https://github.com/rejectedsoftware/vibe.d/blob/master/examples/message/source/app.d