Looking for command for synchronization of threads

[FG]

On 2013-01-31 03:29, Sparsh Mittal wrote:
> Thanks. I wrote this:  [...]
> It compiles but barrier does not get released. Can you please point out the
> fault. Pardon my mistake. I searched whole web, there are almost no examples of
> it online.

Barrier doesn't release because you've only called wait() from one thread, while 
initializing the Barrier to use two threads. The following code works for me. 
Notice that the Barrier and wait() are used in 3 threads. But better have this 
verified by someone who had done more threading in D. :)

     #!/usr/bin/env rdmd

     import std.stdio;
     import std.concurrency;
     import std.algorithm;
     import core.sync.barrier;
     import core.thread;

     __gshared Barrier barrier = null;

     void sorter(Tid owner, shared(int)[] sliceToSort, int mynumber)
     {
         writefln("Came inside  %s", mynumber);
         sort(sliceToSort);
         writefln("Going out of %s", mynumber);
         barrier.wait();
     }

     void main()
     {
         shared numbers = [ 6, 5, 4, 3, 2, 1 ];
         barrier = new Barrier(3);
         spawn(&sorter, thisTid, numbers[0 .. $ / 2], 0);
         spawn(&sorter, thisTid, numbers[$ / 2 .. $], 1);

         writefln("Waiting for barrier in main");
         barrier.wait();
         writefln("All done");

         writeln(numbers);
     }