2

我确实了解BarrierC# 中使用的类。但是，在下面的代码中，我不明白为什么SignalAndWait()被调用了两次？任务中的调用还不够吗？该代码基本上模拟了三个朋友（或任务）从 A 到 B，B 到 C，有些从 B 回到 A 而没有去 C 的情况。请帮帮我。顺便说一句，这段代码来自书中：MCSD Certification Exam Toolkit(70-483)。非常感谢！

static void Main(string[] args) 
{
    var participants = 5;
    Barrier barrier = new Barrier(participants + 1,
        b => { // This method is only called when all the paricipants arrived.
            Console.WriteLine("{0} paricipants are at rendez-vous point {1}.",
                b.ParticipantCount -1, // We substract the main thread.
                b.CurrentPhaseNumber);
        });
    for (int i = 0; i < participants; i++) 
    {
        var localCopy = i;
        Task.Run(() => {
            Console.WriteLine("Task {0} left point A!", localCopy);
            Thread.Sleep(1000 * localCopy + 1); // Do some "work"
            if (localCopy % 2 == 0) {
                Console.WriteLine("Task {0} arrived at point B!", localCopy);
                barrier.SignalAndWait();
            }
            else 
            {
                Console.WriteLine("Task {0} changed its mind and went back!", localCopy);
                barrier.RemoveParticipant();
                return;
            }
            Thread.Sleep(1000 * (participants - localCopy)); // Do some "morework"
            Console.WriteLine("Task {0} arrived at point C!", localCopy);
            barrier.SignalAndWait(); 
        });
    }

    Console.WriteLine("Main thread is waiting for {0} tasks!",
    barrier.ParticipantCount - 1);
    barrier.SignalAndWait(); // Waiting at the first phase
    barrier.SignalAndWait(); // Waiting at the second phase
    Console.WriteLine("Main thread is done!");
}
4

1 回答 1

2

您还将看到该行Console.WriteLine("{0} paricipants are at rendez-vous point {1}.",...)执行了两次。

单个 Barrier 实例用于在 B 和 C 处会合。（剩余的）taks 调用SignalAndWait()以标记它们同时到达 B 和 C，因此进行了两次调用。

精简代码：

   if (localCopy % 2 == 0) 
   {
        ...
        barrier.SignalAndWait();       // arrival at B
    }
    else 
    {
        ...
        barrier.RemoveParticipant();   // return to A
        return;
    }
    ...
    barrier.SignalAndWait();           // arrival at C
于 2014-07-26T20:43:23.623 回答