3

我正在使用 PLINQ 运行一个测试串行端口以确定它们是否是 GPS 设备的函数。

一些串行端口立即被发现是一个有效的 GPS。在这种情况下，我希望第一个完成测试的人是返回的人。我不想等待其余的结果。

我可以使用 PLINQ 执行此操作，还是必须安排一批任务并等待一个任务返回？

4

4 回答 4

7

PLINQ 在这里可能不够用。虽然您可以.First在 .NET 4 中使用 , 但这将导致它按顺序运行，这违背了目的。（请注意，这将在 .NET 4.5 中得到改进。）

然而，TPL 很可能是这里的正确答案。Task<Location>您可以为每个串口创建一个，然后使用Task.WaitAny等待第一个成功操作。

这提供了一种简单的方法来安排一堆“任务”，然后只使用第一个结果。

于 2011-11-11T20:28:04.767 回答
2

在过去的几天里，我一直在思考这个问题，但我在 C# 4.0 中找不到内置的 PLINQ 方法来执行此操作。在完整的 PLINQ 查询完成并且仍然返回（有序的）第一个结果之前，使用FirstOrDefault这个问题的公认答案不会返回值。以下极端示例显示了该行为：

var cts = new CancellationTokenSource();
var rnd = new ThreadLocal<Random>(() => new Random());

var q = Enumerable.Range(0, 11).Select(x => x).AsParallel()
    .WithCancellation(cts.Token).WithMergeOptions( ParallelMergeOptions.NotBuffered).WithDegreeOfParallelism(10).AsUnordered()
    .Where(i => i % 2 == 0 )
    .Select( i =>
    {
        if( i == 0 )
            Thread.Sleep(3000);
        else
            Thread.Sleep(rnd.Value.Next(50, 100));
        return string.Format("dat {0}", i).Dump();
    });

cts.CancelAfter(5000);

// waits until all results are in, then returns first
q.FirstOrDefault().Dump("result");

我没有看到立即获得第一个可用结果的内置方法，但我能够提出两种解决方法。

第一个创建任务来完成工作并返回任务，从而快速完成 PLINQ 查询。生成的任务可以传递给 WaitAny 以在可用时立即获得第一个结果：

var cts = new CancellationTokenSource();
var rnd = new ThreadLocal<Random>(() => new Random());

var q = Enumerable.Range(0, 11).Select(x => x).AsParallel()
    .WithCancellation(cts.Token).WithMergeOptions( ParallelMergeOptions.NotBuffered).WithDegreeOfParallelism(10).AsUnordered()
    .Where(i => i % 2 == 0 )
    .Select( i =>
    {
        return Task.Factory.StartNew(() =>
        {
        if( i == 0 )
            Thread.Sleep(3000);
        else
            Thread.Sleep(rnd.Value.Next(50, 100));
        return string.Format("dat {0}", i).Dump();
        });
    });

cts.CancelAfter(5000);

// returns as soon as the tasks are created
var ts = q.ToArray();

// wait till the first task finishes
var idx = Task.WaitAny( ts );
ts[idx].Result.Dump("res");

这可能是一种糟糕的方法。由于 PLINQ 查询的实际工作只是一个非常快的 Task.Factory.StartNew，所以使用 PLINQ 完全没有意义。A simple .Select( i => Task.Factory.StartNew( ... on the IEnumerable 更干净，可能更快。

第二种解决方法使用队列（BlockingCollection），并且在计算结果后将结果插入此队列：

var cts = new CancellationTokenSource();
var rnd = new ThreadLocal<Random>(() => new Random());

var q = Enumerable.Range(0, 11).Select(x => x).AsParallel()
    .WithCancellation(cts.Token).WithMergeOptions( ParallelMergeOptions.NotBuffered).WithDegreeOfParallelism(10).AsUnordered()
    .Where(i => i % 2 == 0 )
    .Select( i =>
    {
        if( i == 0 )
            Thread.Sleep(3000);
        else
            Thread.Sleep(rnd.Value.Next(50, 100));
        return string.Format("dat {0}", i).Dump();
    });

cts.CancelAfter(5000);

var qu = new BlockingCollection<string>();

// ForAll blocks until PLINQ query is complete
Task.Factory.StartNew(() => q.ForAll( x => qu.Add(x) ));

// get first result asap
qu.Take().Dump("result");

使用这种方法，工作是使用 PLINQ 完成的，并且 BlockingCollecion 的 Take() 将在 PLINQ 查询插入后立即返回第一个结果。

虽然这会产生预期的结果，但我不确定它是否比仅使用更简单的 Tasks + WaitAny 有任何优势

于 2013-10-09T23:58:20.807 回答
0

经过进一步审查，您显然可以使用FirstOrDefault来解决这个问题。默认情况下，PLINQ 不会保留排序，并且对于无缓冲查询，将立即返回。

http://msdn.microsoft.com/en-us/library/dd460677.aspx

于 2011-11-14T14:02:04.623 回答
0

要完全使用 .NET 4.0 中的 PLINQ 完成此任务：

SerialPorts.                        // Your IEnumerable of serial ports
    AsParallel().AsUnordered().     // Run as an unordered parallel query
    Where(IsGps).                   // Matching the predicate IsGps (Func<SerialPort, bool>)
    Take(1).                        // Taking the first match
    FirstOrDefault();               // And unwrap it from the IEnumerable (or null if none are found

关键是不要使用像 First 或 FirstOrDefault 这样的有序评估，直到您指定您只关心找到一个。

于 2017-11-06T15:51:21.543 回答