- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我想并行处理一些项目。此处理是独立的(顺序无关紧要)并返回一个输出。然后应尽快按顺序中继回这些输出。
也就是说,该方法的行为应该等同于此(并行调用 Process
除外):
IEnumerable<T> OrderedParallelImmediateSelect<T> (IEnumerable<object> source)
{
foreach (var input in source) {
var result = Process (input);
yield return result;
}
}
因此,它需要尝试按顺序处理项目。由于这(当然)不能保证按顺序完成,结果收集器必须确保等待延迟的结果。
order 中的下一个结果一进来,就必须立即返回。我们不能等到整个输入都处理完了再对结果进行排序。
这是一个例子:
begin 0
begin 1 <-- we start processing in increasing order
begin 2
complete 1 <-- 1 is complete but we are still waiting for 0
begin 3
complete 0 <-- 0 is complete, so we can return it and 1, too
return 0
return 1
begin 4
begin 5
complete 4 <-- 2 and 3 are missing before we may return this
complete 2 <-- 2 is done, 4 must keep waiting
return 2
begin 6
complete 3 <-- 3 and 4 can now be returned
return 3
return 4
如果可能的话,我想在常规线程池上执行处理。
这种情况是 .NET 提供的解决方案吗?我已经构建了一个自定义解决方案,但更愿意使用更简单的解决方案。
我知道很多类似的问题,但似乎它们都允许等待所有项目完成处理或不保证订购结果。
遗憾的是,这是一个似乎不起作用的尝试。将 IEnumerable
替换为 ParallelQuery
无效。
int Process (int item)
{
Console.WriteLine ($"+ {item}");
Thread.Sleep (new Random (item).Next (100, 1000));
Console.WriteLine ($"- {item}");
return item;
}
void Output (IEnumerable<int> items)
{
foreach (var it in items) {
Console.WriteLine ($"=> {it}");
}
}
IEnumerable<int> OrderedParallelImmediateSelect (IEnumerable<int> source)
{
// This processes in parallel but does not return the results immediately
return source.AsParallel ().AsOrdered ().Select (Process);
}
var input = Enumerable.Range (0, 20);
Output (OrderedParallelImmediateSelect (input));
输出:
+0 +1 +3 +2 +4 +5 +6 +7 +9 +10 +11 +8 -1 +12 -3 +13 -5 +14 -7 +15 -9 +16 -11 +17 -14 +18 -16 +19 -0 -18 -2 -4 -6 -8 -13 -10 -15 -17 -12 -19 =>0 =>1 =>2 =>3 =>4 =>5 =>6 =>7 =>8 =>9 =>10 =>11 =>12 =>13 =>14 =>15 =>16 =>17 =>18 =>19
最佳答案
我创建了这个程序,作为一个控制台应用程序:
using System;
using System.Linq;
using System.Threading;
namespace PlayAreaCSCon
{
class Program
{
static void Main(string[] args)
{
var items = Enumerable.Range(0, 1000);
int prodCount = 0;
foreach(var item in items.AsParallel()
.AsOrdered()
.WithMergeOptions(ParallelMergeOptions.NotBuffered)
.Select((i) =>
{
Thread.Sleep(i % 100);
Interlocked.Increment(ref prodCount);
return i;
}))
{
Console.WriteLine(item);
}
Console.ReadLine();
}
}
}
然后我最初在 Console.WriteLine(item);
上设置了一个断点。运行程序,当我第一次遇到该断点时,prodCount
是 5 - 我们肯定在所有处理完成之前消耗结果。删除断点后,所有结果似乎都按原始顺序生成。
关于c# - 并行订购耗材,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52150533/
我正在尝试以一种可以根据需要循环输出和输出 header 的方式编写 SQL Server 2008 查询。我已经多次以错误的方式完成这些工作,让 ColdFusion 在页面中完成艰苦的工作,但需要
为什么通用寄存器按原样排序(eax、ecx、edx、ebx)?例如,对于“inc”指令,操作码是: inc eax - 40 inc ecx - 41 inc edx - 42 inc ebx - 4
晚上好。 我需要组织一个HashMap,它是这样的: private HashMap>taskOrdered = new HashMap>(); 每个“任务”都是一个具有 3 个属性的类: 人员姓名;
这个问题在这里已经有了答案: C# - sorting by a property (3 个答案) how to sort a collection by datetime in c# (4 个答案
我有以下存储记录和错误的 XML 文档(如果需要可以重新设计)。 11/03/2010 14:12:41 1 11/03/2
关于这个主题有很多问题,仍然无法找到解决这个问题的方法。 我正在做的查询是: SELECT `b`.`ads_id` AS `ads_id`, `b`.`bod_bedrag`
我正在制作一个排名系统。但我想要的是将我得到的结果 ($kn) 从最高到最低排序。我该怎么做? include "includes/core.inc.php"; require "includes/c
我有一个这样的列表, M=[[75], [95, 64], [17, 47, 82], [18, 35, 87, 10], [20, 4, 82, 47, 65], [19, 1, 23, 75, 3
我有 5 个数学问题要解决,30 个人将尝试解决这些问题中的每一个。 我知道每个人解决某个问题的速度有多快: Person1 将能够在 5 秒内解决问题 A,在 7 秒内解决问题 B,在 20 秒内解
考虑 val animals = List("penguin","ferret","cat").toSeq val rdd = sc.makeRDD(animals, 1) 我想订购这个 RDD。我是
我有以下列表: 我的 list [[1]] [1] 11 [[2]] [1] 9 [[3]] [1] 10 我想对它进行排序。我试过了 sort(mylist) Error: mylist must
sort(v; alg::Algorithm=defalg(v), lt=isless, by=identity, rev::Bool=false, order::Ordering=Forward)
我有一个数据框,我想生成一个 geom_tile()从中绘制,但我希望图形的排序不是基于字母顺序而是基于此数据框中的变量。 structure(list(V1 = c("a", "y", "w", "
我列出 Facebook 好友是这样的: FB.api('/me/friends?fields=id,name,updated_time&date_format=U&',
我正在多个线程中的UDP上接收消息。每次接待后,我都会提出MessageReceived.OnNext(message)。 因为我使用多个线程,所以消息无序引发,这是一个问题。 如何通过消息计数器命令
我与两个实体有一对多关系: Order: int OrderId string OrderNumber ... OrderItem: int ItemId int sequence decimal Q
我正在尝试从用户将输入的数字(代码)中对结构进行排序,并且我正在使用冒泡排序。我希望程序打印按数字(代码)排序的所有数据,但它只对数字(代码)进行排序。有人可以帮我对数字(代码)中的其他元素进行排序吗
对于我的通用网格,我目前这样做是为了激活排序: Elements.OrderBy(column.SortExpression).AsQueryable(); 其中SortExpression类型为 F
给定两个 DOM 元素,比如 a 和 b,我们如何确定哪个在文档中排在第一位? 我正在对一组元素实现拖放操作。并且可以以任意顺序选择元素,但是在拖动它们时,需要以“正确”的顺序移动这些元素。 最佳答案
我正在将我们的管理系统从 PHP 迁移到 Ruby On Rails。旧系统的一部分使用 SQL 来构建客户列表,然后按最后一次联系的时间对他们进行排序: SELECT `cust
我是一名优秀的程序员,十分优秀!