如何在没有异步/等待的情况下循环异步方法

Question

如果不使用c＃异步/等待功能，什么才是循环异步操作而不阻塞的最佳方式？

例如，在for循环内异步下载URL列表的HTML。

我继续在TPL的while循环中继续调用自己，如果有更多的工作....但是有没有更好的方法？

Answer 1

您描述的模式并不差，但您可以将它抽象为辅助方法。类似于ForEachAsync或ConvertAllAsync。这可以消除代码中的循环。这将非必要的复杂性降至最低。

---

这里是ForEachAsync实现：

public static Task ForEachAsync<T>(this TaskFactory factory, IEnumerable<T> items, Func<T, int, Task> getProcessItemTask) 
    { 
     TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 

     IEnumerator<T> enumerator = items.GetEnumerator(); 
     int i = 0; 

     Action<Task> continuationAction = null; 
     continuationAction = ante => 
      { 
       if (ante.IsFaulted) 
        tcs.SetException(ante.Exception); 
       else if (ante.IsCanceled) 
        tcs.TrySetCanceled(); 
       else 
        StartNextForEachIteration(factory, tcs, getProcessItemTask, enumerator, ref i, continuationAction); 
      }; 

     StartNextForEachIteration(factory, tcs, getProcessItemTask, enumerator, ref i, continuationAction); 

     tcs.Task.ContinueWith(_ => enumerator.Dispose(), TaskContinuationOptions.ExecuteSynchronously); 

     return tcs.Task; 
    } 
    static void StartNextForEachIteration<T>(TaskFactory factory, TaskCompletionSource<object> tcs, Func<T, int, Task> getProcessItemTask, IEnumerator<T> enumerator, ref int i, Action<Task> continuationAction) 
    { 
     bool moveNext; 
     try 
     { 
      moveNext = enumerator.MoveNext(); 
     } 
     catch (Exception ex) 
     { 
      tcs.SetException(ex); 
      return; 
     } 

     if (!moveNext) 
     { 
      tcs.SetResult(null); 
      return; 
     } 

     Task iterationTask = null; 
     try 
     { 
      iterationTask = getProcessItemTask(enumerator.Current, i); 
     } 
     catch (Exception ex) 
     { 
      tcs.SetException(ex); 
     } 

     i++; 

     if (iterationTask != null) 
      iterationTask.ContinueWith(continuationAction, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, factory.Scheduler ?? TaskScheduler.Default); 
    }