加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

c# – 组合等待手柄?

发布时间:2020-12-15 21:13:56 所属栏目:百科 来源:网络整理
导读:我觉得这里有点有趣.我有一个类负责将多个处理操作“多路复用”到固定数量的线程上.典型的情况是一种生产者/消费者问题,其中每个操作都包含一个WaitHandle(在这种情况下,跟踪队列中有多少项的信号量)和一个要调用的委托. 例如,如果我有两个生产者(A和B),则将
我觉得这里有点有趣.我有一个类负责将多个处理操作“多路复用”到固定数量的线程上.典型的情况是一种生产者/消费者问题,其中每个操作都包含一个WaitHandle(在这种情况下,跟踪队列中有多少项的信号量)和一个要调用的委托.

例如,如果我有两个生产者(A和B),则将项目生成两个单独的队列.我没有为每个生产者创建两个消费者线程(A1,A2,B1,B2),而是将四个消费者“线程”复用到两个线程上.这个“多路复用器”的代码运行类似这样(简化了一点):

WaitHandle[] waitHandles = new WaitHandle[2];
waitHandles[0] = NumberOfItemsFullInProducerAQueue;
waitHandles[1] = NumberOfItemsFullInProducerBQueue;
while(true)
{
    int index = WaitHandle.WaitAny(waitHandles);
    if(index == 0)
    {
        // handle the item from queue A
    }
    else
    {
        // handle the item from queue B
    }
}

我试图将这个概念扩展到一个稍微复杂的例子,其中一个动作可能需要在执行之前满足多个等待句柄.我想知道是否有某种WaitHandle.Combine(waitHandle1,waitHandle2)调用我可以将两个等待句柄组合成一个等待句柄.最终结果将是这样的:

A,B,C,D are waitHandles
E = Combine(A,B)
F = Combine(C,D)
waitHandles = { E,F }

while(true)
{
   int index = WaitHandle.WaitAny(waitHandles);
   if(index == 0)
   {
   }
   else
   {
   }
}

加分?

虽然不是必需的,但如果等待句柄的组合可以相交,那么它也可能非常好.例如,像这样:

A,C are waitHandles
  D = Combine(A,B)
  E = Combine(A,C)
  waitHandles = { D,E }
  // same as above from here

谢谢你的帮助

解决方法

您可以考虑在.NET 4 TPL中查看新的 Barrier类(作为 Reactive Extensions的一部分反向移植到3.5).它专门针对您描述的场景而设计,您需要阻止执行,直到多个协作任务到达检查点.您还可以使用任务系统创建复杂的延续路径,其中一个任务取决于先前完成的两个,取决于第一个任务完成,如果在任何时候发生异常,则在中心位置聚合和报告这些异常.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读