C#異步迭代IAsyncEnumerable應用實現(xiàn)

更新時間：2021年06月28日 10:42:09 作者：魯廣廣

IAsyncEnumerable可以來實現(xiàn)異步迭代，本文就主要介紹了C#異步迭代IAsyncEnumerable應用實現(xiàn)，具有一定的參考價值，感興趣的小伙伴們可以參考一下

最近用WPF做金稅盤開發(fā)中有這樣一個需求，批量開票每次開票都需要連接一次金稅盤。

比如我有發(fā)票 a, b ,c ,d e 這五張發(fā)票，每次開具發(fā)票都需要調(diào)用金稅盤底層，才能正常開票。

首先，嘗試寫第一個方法

private  void Button_Click(object sender, RoutedEventArgs e)
        {
            var dateStart = DateTime.Now;  //記錄用時的起始時間
            DebugText = string.Empty;
            List<string> fpList = new List<string>() { "a", "b", "c", "d" };

            foreach (var item in MockIO)
            {
                var dateEnd = DateTime.Now;
                var timeSpan = dateEnd - dateStart;//記錄開票用時
                DebugText += item + " " + timeSpan.TotalSeconds + "\r\n";

            }
        }

     /// <summary>
        /// 批量開票方法
        /// </summary>
        /// <param name="ls"></param>
        /// <returns></returns>
        public static IEnumerable<string> MockIO(List<string> ls)
        {

            foreach (var item in ls)
            {
                Task.Delay(1000).Wait();
                yield return item;
                Debug.WriteLine(Thread.GetCurrentProcessorId());
            }
        }

來看效果

很明顯，發(fā)生了UI阻塞情況。因為我們并未對代碼做任何異步處理。接下來，我們開始嘗試修改。

首先，我們嘗試按照常規(guī)異步方法修改 MockIO 函數(shù)，增加 async 關鍵詞，返回結(jié)果增加 Task，內(nèi)部對IO操作添加 await。

修改完畢后，編譯并沒有通過，VS對該方法報異常

通過提示信息，我們可以發(fā)現(xiàn)，返回值 Task<IEnumerable<string>> 并不是可以迭代的，因為我們采用了 yield 來返回值，所以我們需要一個可以迭代的返回值。

比如改成這樣

但是，這樣一次就返回一組 Task ，沒有用到方便的 yield;

此時，就可以用到 IAsyncEnumerable 來設計了，IAsyncEnumerable是C# 8.0引入的新特性，在異步迭代中，非常方便。如上述代碼，可以直接修改為

public static async IAsyncEnumerable<string> MockIOAsync(List<string> ls)
        {
            foreach (var item in ls)
            {
                Task<Task<string>> task = Task<Task<string>>.Factory.StartNew(async () =>
               {
                   await Task.Delay(1000);
                   return item;

               });

                yield return await task.Result;
            }
        }

我們再運行調(diào)試，看一下效果

我們可以看到，不僅UI沒有被阻塞，同時，傳回的值也是一個接一個的傳過來的，符合我們的預期。

擴展：雖然上述步驟我們完成的UI的非阻塞的實現(xiàn)，但是我們整個開票用時并沒有節(jié)省。

接下來，我將繼續(xù)修改 MockIOAsync 方法，將實現(xiàn)迭代器內(nèi)部的多線程操作。

修改后的代碼如下

public static async Task<IEnumerable<string>> MockIOPerformanceAsync(List<string> ls)
        {
            List<string> lss = new List<string>();
            List<Task> tasks = new List<Task>();
            foreach (var item in ls)
            {

                Task task = new Task(() =>
              {
                  Task.Delay(1000).Wait();
                  Debug.WriteLine(Thread.GetCurrentProcessorId());
                  lss.Add(item);
              });
                tasks.Add(task);
                task.Start();

            }
            foreach (var item in tasks)
            {
                await item;
            }
            return lss;
        }

效果展示：