3

在这个问题（及其答案）之后，我想使用 TaskCompletionSource 并Task.WhenAll等到任何任务首先返回 True 。所以我写了这个：

TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();
Task<bool> t0 = Task.Factory.StartNew<bool>(() => Find(paramA, paramB);
Task<bool> t1 = Task.Factory.StartNew<bool>(() => Find(paramC, paramD);
Task<bool> t2 = Task.Factory.StartNew<bool>(() => Find(paramE, paramF);
Task<bool> t3 = Task.Factory.StartNew<bool>(() => Find(paramG, paramH);

t0.ContinueWith(_ =>
{
    if (t0.Result)
        tcs.TrySetResult(t0.Result);
});

t1.ContinueWith(_ =>
{
    if (t1.Result)
        tcs.TrySetResult(t1.Result);
});

t2.ContinueWith(_ =>
{
    if (t2.Result)
        tcs.TrySetResult(t2.Result);
});

t3.ContinueWith(_ =>
{
    if (t3.Result)
        tcs.TrySetResult(t3.Result);
});

t4.ContinueWith(_ =>
{
    if (t4.Result)
        tcs.TrySetResult(t4.Result);
});

tcs.Task.Wait();
return tcs.Task.Result;

当任何任务返回时，它都可以正常工作true，但是正如之前的答案中所注意到的：

当所有任务都返回 false 时，需要注意的一点是……在 .NET 4.5 中，通过通过 Task.WhenAll 创建另一个任务，这将相当容易

所以我尝试玩，Task.WhenAll但我不想正确使用它......
我尝试了类似的东西：

tcs.Task.Wait(); // stays block here when all tasks return false
Task tr = Task.WhenAll(new Task[] { t0, t1, t2, t3, t4 });

if (tr.IsCompleted)
   return false;
else
return tcs.Task.Result;

谢谢您的帮助

4

2 回答 2

5

您想等到完成两项任务之一，这Task.WaitAny()就是：

Task tr = Task.WhenAll(new Task[] { t0, t1, t2, t3, t4 });
Task.WaitAny(tcs.Task, tr);

if (tcs.Task.IsCompleted)
    return tcs.Task.Result;

return false;

这也修复了代码中的竞争条件：tr.IsCompleted可能是true，即使返回了某些任务true，因为所有任务都可以同时完成。

作为替代方案，您可以使用Task.WhenAny()，如果您不想阻止。

但是，由于您使用的是 .Net 4.5，您不妨await与方法一起使用Interleaved()，该方法在任务完成时对任务进行排序：

async Task<bool> AnyTrue(IEnumerable<Task<bool>> tasks)
{
    foreach(var bucket in Interleaved(tasks))
    {
        if (await await bucket)
            return true;
    }

    return false;
}
于 2012-08-07T21:07:51.493 回答
2

要检查结果，false您可以使用

if (!task.Result)
{ 
    // Do stuff...
}

这将检查布尔结果是否为假。为了更完整，你可以做类似的事情

asyncTask.ContinueWith(task =>
{
    // Check task status.
    switch (task.Status)
    {
        case TaskStatus.RanToCompletion:
            if (asyncTask.Result)
            {
                // returned true.
            }
            else
            {
                // returned false
            }
            break;
        default:
            break;
    }
}

我希望这有帮助。

于 2012-08-07T09:42:44.437 回答