深入多线程之:解析线程的交会(Thread Rendezvous)详解

在上篇文章中我们使用了wait和pulse 实现了countdown

接下来我们可以使用刚刚写的countdown 类来实现两个线程的交会。

class rendezvous
    {
        static object _locker = new object();
        static countdown _countdown = new countdown(2);

        public static void mainthread()
        {
            random r = new random();
            new thread(mate).start(r.next(1000));
            thread.sleep(r.next(10000)); //主线程睡眠一段时间

            _countdown.singnal(); //向_countdown注册信号，告知主线程已经来了。
            _countdown.wait();    //等待其他线程

            console.writeline("mate!");
        }

        static void mate(object delay)
        {
            thread.sleep((int)delay);//线程睡眠。

            _countdown.singnal(); //向_countdown注册信号，告知线程已经来了。
            _countdown.wait();   //等待其他线程。

            console.writeline("mate!");

        }
}

就像小时候去春游一样，这里的_countdown就是老师，线程就是学生。

学生a早上睡觉，然后起床来到交会点，然后告诉老师，我来了，接着等待老师的出发命令，因为老师知道有两个学生要去春游，所以现在只来了一个，还有一个没有来，所以老师会让学生a等待，阻塞。

学生b也是睡觉，接着也来到交会点，告诉老师，我也来了，然后等待老师的出发命令。

当学生b告诉老师我来了的时候，此时老师的剩余等待学生计数为0，所以老师告诉这两个学生，你们可以出发了。

.net framework 4.0 提供了barrier 的构造来实现线程交会的功能。如图所示：

thread1 调用signalandwait告知barrier，我已经来了，然后阻塞。

thread3调用signalandwait告知barrier，我已经来了，然后阻塞。

thread2 调用signalandwait告知barrier，我已经来了，barrier知道现在三个线程都来了，所以让他们继续并发执行。

barrier的方法简介：

    addparticipants:增加参与者，也就是增加春游的人数。
    removeparticipant：减少参与者，可能某人肚子痛，不能参加春游了。
    signalandwait ：参与者已经来了，并等待其他参与者的到来。

下面是使用barrier的示例：

static barrier _barrier = new barrier(3);//说明有三个参与者

        public static void main()
        {
            new thread(speak).start();
            new thread(speak).start();
            new thread(speak).start();
        }

        static void speak()
        {
            for (int i = 0; i < 5; i++)
            {
                console.write(i + " ");
                _barrier.signalandwait(); //告知参与者已经来了，等待其他参与者
            }
        }

输出如下：

0 0 0 1 1 1 2 2 2 3 3 3 4 4 4

barrier 的另一个非常有用的特性是在每一个阶段完成的时候你都可以执行一个post-phase 的action委托。

什么是阶段呢？？，阶段就是参与者全部都到了的时候。

如果我们修改barrier的构造函数如下：

static barrier _barrier = new barrier(3, (barrier) => console.writeline());

//说明有三个参与者,并且每次三个参与者完成任务的时候执行console.writeline方法.

那么我们的输出如下所示：

0 0 0

1 1 1

2 2 2

3 3 3

4 4 4