非同期ストリームの使用上の注意事項
非同期ストリームはC#8.0の特性であり、以前のようにすべてのデータを取得してから返すのではなく、ストリームデータをできるだけ早くバッチで返すことができます.
次の例のシーンは少し特殊で、1つの多いデータをクエリーして、クエリーがデータに大きな圧力を与えないように、1つのバッチを作ってデータからデータをクエリーして、1つの整理リストに組み立てて返します.
以前のやり方であれば、すべてのデータが戻ってきたら、1つのセットに累積してから戻る必要があります.非同期ストリームを使用すると、バッチを返すことができ、ユーザーがより速く表示または使用できるように戻ります.
非同期ストリームにも問題があり、複数回返されます.ユーザー体験は比較的良いですが、時間がかかります.次の例で説明します.
次の例のシーンは少し特殊で、1つの多いデータをクエリーして、クエリーがデータに大きな圧力を与えないように、1つのバッチを作ってデータからデータをクエリーして、1つの整理リストに組み立てて返します.
以前のやり方であれば、すべてのデータが戻ってきたら、1つのセットに累積してから戻る必要があります.非同期ストリームを使用すると、バッチを返すことができ、ユーザーがより速く表示または使用できるように戻ります.
非同期ストリームにも問題があり、複数回返されます.ユーザー体験は比較的良いですが、時間がかかります.次の例で説明します.
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Net.WebSockets;
using System.Text;
using System.Threading.Tasks;
using System.Diagnostics;
using System.Security.Cryptography;
using System.IO;
using Dapper;
namespace KeyWordsDemo
{
class AsyncStreamDemo : IDemoAsync
{
public async Task RunAsync()
{
Console.WriteLine("1、 2、 ")
var no = Console.ReadLine();
var producer = new Producer();
if(no == "1")
{
var watch = new Stopwatch();
watch.Start();
await foreach (var orders in producer.EnumerateOrdersAsync())
{
foreach (var order in orders)
{
Console.WriteLine(order.ToString());
}
}
watch.Stop();
Console.Title = $" :{ watch.Elapsed.TotalSeconds}";
}
else
{
var watch = new Stopwatch();
watch.Start();
var orders = await producer.GetOrdersAsync();
foreach (var order in orders)
{
Console.WriteLine(order.ToString());
}
watch.Stop();
Console.Title = $" :{orders.Count()} :{ watch.Elapsed.TotalSeconds}";
}
Console.ReadLine();
}
}
class Producer
{
public async Task> GetOrdersAsync()
{
var orders = new List();
var offset = 0;
while (true)
{
var list = (await QueryOrdersAsync(offset)).ToList();
orders.AddRange(list);
offset++;
if (list.Count < 100)
{
break;
}
}
return orders;
}
public async IAsyncEnumerable> EnumerateOrdersAsync()
{
var offset = 0;
while (true)
{
var list = (await QueryOrdersAsync(offset)).ToList();
yield return list;
offset++;
if (list.Count < 100)
{
break;
}
}
}
public async Task> QueryOrdersAsync(int offset)
{
using var con = new SqlConnection("server=.;database=AdventureWorks2016;uid=sa;pwd=sa;");
var sql = @$"select * from Sales.SalesOrderDetail order by SalesOrderID,SalesOrderDetailID offset {offset * 100} row fetch next 100 row only";
return await con.QueryAsync(sql);
}
}
class SalesOrderDetail
{
public int SalesOrderID { get; set; }
public string CarrierTrackingNumber { get; set; }
public short OrderQty { get; set; }
public int ProductID { get; set; }
public int SpecialOfferID { get; set; }
public decimal UnitPrice { get; set; }
public decimal UnitPriceDiscount { get; set; }
public Guid rowguid { get; set; }
public DateTime ModifiedDate { get; set; }
public override string ToString()
{
return System.Text.Json.JsonSerializer.Serialize(this);
}
}
}