首页 > Python基础教程 >
-
C#教程之学习笔记——异步
1.异步同步的定义
同步方法:多个任务一个一个执行,同一时刻系统中只有一个任务在执行
异步方法:发起一个调用,并不等着计算结束,而是直接去运行下一行;刚才的计算,会启动一个新的线程去执行
2.异步同步的比较
2.1. 同步方法卡界面,因为UI线程忙于计算;异步多线程方法不卡界面,主线程闲置,计算任务交给子线程在做;
2.2. 同步方法慢,只有一个线程计算;异步多线程方法快,多个线程并发计算;
多线程的资源消耗更多,线程并不是越多越好(资源有限/管理线程也消耗资源)
2.3. 异步多线程是无序的:启动无序 执行时间不确定 结束无序,,
所以不要试图通过启动顺序或者时间等待来控制流程
3.异步如何控制执行顺序
3.1.回调
//IasyncResult,可用于监视调用进度
//DoSomethingLong方法名称(要执行的操作)
Action<string> act = this.DoSomethingLong;
IAsyncResult iAsyncResult = null;
AsyncCallback callback = ar =>
{
// Console.WriteLine(object.ReferenceEquals(ar, iAsyncResult));
Console.WriteLine(ar.AsyncState);
Console.WriteLine($"这里是BeginInvoke调用完成之后才执行的。。。{Thread.CurrentThread.ManagedThreadId.ToString("00")}");
};
iAsyncResult = act.BeginInvoke("btnAsync_Click", callback, "异步学习");
3.2.等待
//IAsyncResult.IsCompeted确定异步调用何时完成(轮询)
Action<string> act = this.DoSomethingLong;
IAsyncResult iAsyncResult = act.BeginInvoke("btnAsync_Click", null, null);
int i = 1;
while (!iAsyncResult.IsCompleted)//1 卡界面,主线程在等待 2 边等待边做事儿 3有误差(时间)
{
if (i < 10)
{
Console.WriteLine($"文件上传{i++ * 10}%。。。请等待");
}
else
{
Console.WriteLine("已完成99%。。。马上结束");
}
Thread.Sleep(200);//误差时间
}
Console.WriteLine("文件上传成功!!!");
3.3.状态
//使用 IAsyncResult.AsyncWaitHandle 获取 WaitHandle,使用它的 WaitOne 方法将执行一直阻塞到发出 //WaitHandle 信号,然后调用
Action<string> act = this.DoSomethingLong;
IAsyncResult iAsyncResult = act.BeginInvoke("btnAsync_Click", null, null);
//异步变同步(状态)
iAsyncResult.AsyncWaitHandle.WaitOne();//一直等待任务完成,第一时间进入下一行
iAsyncResult.AsyncWaitHandle.WaitOne(-1);//一直等待任务完成,第一时间进入下一行
//最多等待1000ms,超时控制
iAsyncResult.AsyncWaitHandle.WaitOne(1000);//最多等待1000ms,否则就进入下一行,可以做一些超时控制
//调用 BeginInvoke 后可随时调用 EndInvoke 方法;如果异步调用未完成,EndInvoke 将一直阻塞到
//异步调用完成。
act.EndInvoke(iAsyncResult);//等待
4.其他相关知识
任何的异步多线程,都是跟委托相关。委托中的Invoke方法 是同步的。BeginInvoke开始一个异步的请求,调用线程池中一个线程来执行。
4.1.异步获取返回值
Func<int, string> func = i => i.ToString();
IAsyncResult iAsyncResult = func.BeginInvoke(DateTime.Now.Year, ar =>
{
string resultIn = func.EndInvoke(ar);//对于每个异步操作,只能调用一次 EndInvoke。
Console.WriteLine($"This is {ar.AsyncState} 的异步调用结果 {resultIn}");
}, "异步参数");
//string result = func.EndInvoke(iAsyncResult);//获取返回值