我认为下面的代码会让所有10个线程一次运行两个,然后在调用Release()10次后打印“done”.但那不是发生了什么:
int count = 0; Semaphore s = new Semaphore(2,2); for (int x = 0; x < 10; x++) { Thread t = new Thread(new ThreadStart(delegate() { s.WaitOne(); Thread.Sleep(1000); Interlocked.Increment(ref count); s.Release(); })); t.Start(x); } WaitHandle.WaitAll(new WaitHandle[] { s }); Console.WriteLine("done: {0}",count);
输出:
done: 6
如果实现我正在寻找的功能的唯一方法是将EventWaitHandle传递给每个线程,然后对那些EventWaitHandles的数组执行WaitAll(),那么在仅数组上执行WaitAll()的含义是什么信号量?换句话说,等待线程何时解除阻塞?
解决方法
WaitHandle.WaitAll(new WaitHandle [] {s});等待s.WaitOne();.它在第一次机会进入.您似乎希望此调用等待所有其他信号量操作,但操作系统无法区分它们.此命令可能是第一个被授予访问信号量的命令.
我认为你需要的是障碍课.它用于fork-join-style并行.