spawn and wait

[Puming via Digitalmars-d-learn]

On Thursday, 3 July 2014 at 04:51:07 UTC, Ali Çehreli wrote:
> On 07/02/2014 08:29 PM, Puming wrote:
>
> > I want to spawn several similar tasks and then wait for all
> of them to
> > complete to go on do some other things
>
> If you don't care about account for each of them individually, 
> core.thread.thread_joinAll would work. The following program 
> starts two waves of threads and waits for both of the waves to 
> complete:
>
> import std.stdio;
> import std.concurrency;
> import core.thread;
>
> void foo(Duration duration)
> {
>     writefln("Working for %s", duration);
>     Thread.sleep(duration);
> }
>
> void spawnThreads(size_t count)
> {
>     foreach (i; 0 .. count) {
>         spawn(&foo, (i + 1).seconds);
>     }
>     writefln("Started %s workers", count);
> }
>
> void main()
> {
>     spawnThreads(2);
>     writefln("Waiting for all to finish");
>     thread_joinAll();
>
>     spawnThreads(3);
>     writefln("Waiting for all to finish");
>     thread_joinAll();
> }
>
> Ali

Thanks that is what I'm looking for