C# 多线程系列之异步回调(委托)
时间:2022-04-24
本文章向大家介绍C# 多线程系列之异步回调(委托),主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
本文参考自C#基础:线程之异步回调(委托),纯属读书笔记
在解析异步回调之前,先看同步回调的执行过程,以及代码原理。
1、线程的同步执行
同步执行:在主线程执行的时候,主线程调用一个其它方法,此时主线程阻塞,等待调用方法执行完成后主线程才能继续执行。
代码如下:
class Program
{
static void Main(string[] args)
{
for (int i = 1; i < 11; i++) {
if (i == 5) {
Console.WriteLine("调用TakeAWhile方法并等待其执行完成");
Console.WriteLine("开始执行TakeAWhile方法,时间:{0}", DateTime.Now);
int result = TakeAWhile(0, 6000);
if (result == 1) {
Console.WriteLine("TakeAWhile方法执行完成");
}
Console.WriteLine("TakeAWhile方法执行完毕,时间:{0}", DateTime.Now);
}
Thread.Sleep(30);
Console.WriteLine(i.ToString());
}
}
static int TakeAWhile(int data, int time) {
Thread.Sleep(time);
return ++data;
}
}
从上面的结果得出当程序开始调用TakeAWhile方法后,主线程阻塞,当TakeAWhile方法调用完毕之后,主线程又重新开始运行,这个过程就是线程的同步执行的过程.
2、线程的异步执行
what is 异步执行?
异步执行:在主线程执行的时候,打开一个子线程,主线程不会像同步执行的那样等待子线程的结果返回后在执行,主线程会继续执行,当主线程需要子线程的运行结果时,主线程直接调用子线程的运行结果,如果子线程的运行结果还没有出来,那么主线程等待,直到子线程执行结束,主线程拿到子线程的运行结果,主线程在继续。
class Program
{
static void Main(string[] args)
{
Func<int, int, int> fun = TakeAWhile;
IAsyncResult ar = fun.BeginInvoke(0, 1000, null, null);//主线程调用子线程开始执行TakeAWhile方法,并给它传递了参数
int times=1;
while (!ar.IsCompleted)
{
//当子线程没有完成之前,主线程可以在该while语句块内进行任何后续操作,而且不用等待子线程的结束
Console.WriteLine(times++);
Thread.Sleep(50);
}
int result = fun.EndInvoke(ar);//1秒之后我需要子线程的结果了,ok,从子线程中拿到结果
Console.WriteLine("TakeAWhile方法结束,时间是:{0}", DateTime.Now);
Console.WriteLine("result:{0}", result);
Console.ReadKey();
}
static int TakeAWhile(int data, int times)
{
Console.WriteLine("TakeAWhile方法开始执行,时间是:{0}",DateTime.Now);
Thread.Sleep(times);
return ++data;
}
}
从结果和代码进行分析,当通过BeginInvoke方法开始异步执行TakeAWhile方法,主线程继续执行,然后通过IsCompleted属性判断TakeAWhile是否执行完成,最后获取子线程的输出值,并输出其结果,整个过程主线程没有因为在执行子线程的原因,而造成阻塞
注:
因为多线程,导致了这个情况,开启子线程和执行子线程中的方法都需要时间,所以主线程的执行速度快于子线程,所以先输出了一个1;解决方法很简单,让主线程休息一会,等子线程先初始化完,代码如下:
class Program
{
static void Main(string[] args)
{
Func<int, int, int> fun = TakeAWhile;
IAsyncResult ar = fun.BeginInvoke(0, 1000, null, null);//主线程调用子线程开始执行TakeAWhile方法,并给它传递了参数
Thread.Sleep(30);//休息一会
int times=1;
while (!ar.IsCompleted)
{
//当子线程没有完成之前,主线程可以在该while语句块内进行任何后续操作,而且不用等待子线程的结束
Console.WriteLine(times++);
Thread.Sleep(50);
}
int result = fun.EndInvoke(ar);//6秒之后我需要子线程的结果了,ok,从子线程中拿到结果
Console.WriteLine("TakeAWhile方法结束,时间是:{0}", DateTime.Now);
Console.WriteLine("result:{0}", result);
Console.ReadKey();
}
static int TakeAWhile(int data, int times)
{
Console.WriteLine("TakeAWhile方法开始执行,时间是:{0}",DateTime.Now);
Thread.Sleep(times);
return ++data;
}
}
3、异步回调
what is 异步异步回调?
异步回调:主线程在执行的时候,打开一个子线程,主线程继续执行,当子线程执行完成的时候,主线程立即输出子线程的运行结果,主线程继续执行。
class Program
{
static void Main(string[] args)
{
Func<int, int, int> fun = TakeAWhile;
fun.BeginInvoke(0, 1000, TakesAWhileCallBack, fun);//异步调用TakeAWhile,并指定回调函数TakesAWhileCallBack
for (int i = 0; i < 20; i++)
{
Console.WriteLine(i.ToString());
Thread.Sleep(100);
}
Console.ReadKey();
}
static int TakeAWhile(int data, int times) {
Console.WriteLine("TakeAWhile方法开始执行,时间是:{0}", DateTime.Now);
Thread.Sleep(times);
return ++data;
}
/// <summary>
/// 回调函数
/// </summary>
/// <param name="fun">调用的委托</param>
static void TakesAWhileCallBack(IAsyncResult fun)
{
if (fun == null)
throw new ArgumentNullException("fun");
Func<int, int, int> dl = (Func<int, int, int>)fun.AsyncState;
int result = dl.EndInvoke(fun);
Console.WriteLine("我是回调函数返回的结果:{0}", result);
Console.WriteLine("TakeAWhile执行完成,时间是:{0}", DateTime.Now);
}
}
- .Net 转战 Android 4.4 日常笔记(1)--工具及环境搭建
- ASP.NET MVC5+EF6+EasyUI 后台管理系统(33)-MVC 表单验证
- 如何利用深度学习识别千万张图片?
- ASP.NET MVC5+EF6+EasyUI 后台管理系统(32)-swfupload多文件上传[附源码]
- ASP.NET MVC5+EF6+EasyUI 后台管理系统(31)-MVC使用RDL报表
- 43 Hot Flex and ActionScript 3.0 APIs, tips and tools for Autumn 2008
- 异步数据存储
- 谈谈基于SQL Server 的Exception Handling[中篇]
- C# AD(Active Directory)域信息同步,组织单位、用户等信息查询
- 如何仅使用TensorFlow C+来训练深度神经网络
- 捕获silverlight滚轮事件
- ASP.NET MVC5+EF6+EasyUI 后台管理系统(30)-本地化(多语言)
- ASP.NET MVC5+EF6+EasyUI 后台管理系统(29)-T4模版
- ASP.NET MVC5+EF6+EasyUI 后台管理系统(28)-系统小结
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 用高斯计算磷光发射能
- Android So动态加载 优雅实现与原理分析
- 堆与栈区别
- 在Gaussian16中同时扫描两个反应坐标
- python调试神器traceback
- Centos安装高版本GCC
- Django+Vue开发生鲜电商平台之5.使用DRF实现商品列表页和过滤
- Spring 注入集合的成员变量属性
- 深入理解JVM(③)Java的锁优化
- 解Bug之路-Nginx 502 Bad Gateway
- bootstrap v4 toast轻提示正确用法
- 精华 | SQL注入万能Bypass技巧
- 【STM32F429开发板用户手册】第31章 STM32F429的SPI总线基础知识和HAL库API
- Linux 查找当前目录下所有包含指定内容的文件
- 父子管道更有效地扩展应用及其存储库结构