C#语言BatchedJoinBlock
示例
(从2-3个输入中收集一定数量的总计项,并将它们分组为一组数据项的元组)
BatchedJoinBlock<T1,T2,...>在某种意义上是BatchBlock和JoinBlock<T1,T2,...>的组合。
而JoinBlock<T1,T2,...>用于将来自每个目标的一个输入聚合到一个元组中,而BatchBlock用于将N个输入聚合到一个集合中,BatchedJoinBlock<T1,T2,...>用于收集来自不同目标的N个输入所有目标都变成集合的元组。
散布/聚集
考虑一个分散/聚集问题,其中启动了N个操作,其中一些操作可能成功并产生字符串输出,而另一些操作可能失败并产生Exception。
var batchedJoin = new BatchedJoinBlock<string, Exception>(10);
for (int i=0; i<10; i++)
{
Task.Factory.StartNew(() => {
try { batchedJoin.Target1.Post(DoWork()); }
catch(Exception ex) { batchJoin.Target2.Post(ex); }
});
}
var results = await batchedJoin.ReceiveAsync();
foreach(string s in results.Item1)
{
Console.WriteLine(s);
}
foreach(Exception e in results.Item2)
{
Console.WriteLine(e);
}TPL数据流简介,作者:StephenToub
热门推荐
10 八一幼儿祝福语大全简短
11 公司乔迁食堂祝福语简短
12 婚礼结束聚餐祝福语简短
13 儿媳买车妈妈祝福语简短
14 毕业送礼老师祝福语简短
15 同事辞职正常祝福语简短
16 恭贺新婚文案祝福语简短
17 金店立秋祝福语简短英文
18 婆婆高寿祝福语大全简短