如果电流失败，如何继续队列中的其他任务？

Question

我有一些代码，如下

private static void ExecuteOnTaskFailure(Task previousTask) 
{ 
    if (!previousTask.IsFaulted) 
     return; 

    if (previousTask.Exception != null && previousTask.Exception.InnerExceptions != null) 
     foreach (var exception in previousTask.Exception.InnerExceptions) 
     { 
      Logger.Error("Task failed continued to the next task : " + exception.Message, exception); 
     } 
} 

这不工作执行像下面

Queue 
    .GetConsumingEnumerable() 
    .ToObservable() 
    .Select(x => x.ObserveOn(NewThreadScheduler.Default)) 
    .SubscribeOn(NewThreadScheduler.Default) 
    .Subscribe(
     grp => grp.ForEachAsync(b => b.Execute()) 
        .ContinueWith(ExecuteOnTaskFailure, TaskContinuationOptions.OnlyOnFaulted)); 

方法ExecuteOnTaskFailure被定义的队列。我似乎无法弄清楚如何让队列中的任务继续执行，即使其中一个任务执行失败。我还有一种方法可以在排队结束时重新排除这个失败的任务吗？

这里的任何帮助，非常感谢。

Answer 1

这听起来像你想要的是一个try - 在循环catch：

grp.ForEachAsync(async b => 
{ 
    try 
    { 
     await b.Execute(); 
    } 
    catch (Exception ex) 
    { 
     Logger.Error(ex); 
     Queue.Add(b); 
    } 
}) 

但BlockingCollection不是很异步友好，因为它可以阻止（顾名思义），当它是空的。你可能想要考虑一种不同的方法。