博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
异步和多线程,委托异步调用,Thread,ThreadPool,Task,Parallel,CancellationTokenSource
阅读量:4949 次
发布时间:2019-06-11

本文共 9231 字,大约阅读时间需要 30 分钟。

1 进程-线程-多线程,同步和异步

2 异步使用和回调
3 异步参数
4 异步等待
5 异步返回值

5 多线程的特点:不卡主线程、速度快、无序性

7 thread:线程等待,回调,前台线程/后台线程,
8 threadpool:线程池使用,设置线程池,ManualResetEvent
9 Task初步接触

10 task:waitall waitany continueWhenAny continueWhenAll 

11并行运算Parallel

12 异常处理、线程取消、多线程的临时变量和lock

13 Await/Async

                                                             Anker_张(博客园)http://www.cnblogs.com/AnkerZhang/ //简单同步委托、方法调用 val是返回值            Func
func1 = i => { string result = i + "变返回值"; return result; }; string val= func1.Invoke(100); //委托、方法异步调用 func1.BeginInvoke(100, null, null);//开启新的进程去执行方法 IAsyncResult asyncResult = null;//表示异步操作的状态。 AsyncCallback callback = t => //回调函数方法处理 { Console.WriteLine(t.Equals(asyncResult));//运行起来是true Console.WriteLine(t.AsyncState);//t.AsyncState回调函数所需要传的参数 Console.WriteLine("这里是回调函数 {0}", Thread.CurrentThread.ManagedThreadId);//表示线程ID }; asyncResult = func1.BeginInvoke(100, callback, "我是回调函数参数");//参数1:委托所需int参数,2:穿入回调函数,3:回调函数参数,返回值是回调函数 bool b = asyncResult.IsCompleted;//指示异步操作是否已完成。 返回结果: 如果操作完成则为 true,否则为 false。 asyncResult.AsyncWaitHandle.WaitOne();//一直等待 asyncResult.AsyncWaitHandle.WaitOne(-1);//一直等待 asyncResult.AsyncWaitHandle.WaitOne(1000);//等待1000毫秒,超时就不等待了 func1.EndInvoke(asyncResult);//会一直等待回调函数执行完成

委托的异步调用

 异步多线程的三大特点:
1 同步方法卡界面,原因是主线程被占用;异步方法不卡界面,原因是计算交给了别的线程,主线程空闲
2 同步方法慢,原因是只有一个线程计算;异步方法快,原因是多个线程同时计算,但是更消耗资源,不宜太多
3 异步多线程是无序的,启动顺序不确定、执行时间不确定、结束时间不确定

     ///         /// 执行动作:耗时而已        ///         private static void TestThread(string threadName)        {            Console.WriteLine("TestThread Start  Name={2}当前线程的id:{0},当前时间为{1},", System.Threading.Thread.CurrentThread.ManagedThreadId, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff"), threadName);            long sum = 0;            for (int i = 1; i < 999999999; i++)            {                sum += i;            }            Console.WriteLine("TestThread End  Name={2}当前线程的id:{0},当前时间为{1},计算结果{3}", System.Threading.Thread.CurrentThread.ManagedThreadId, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff"), threadName, sum);        }
//多线程            Stopwatch watch = new Stopwatch();//用于计时器            watch.Start();//开始计时            Console.WriteLine();            Console.WriteLine("***********************btnThread_Click Start 主线程id {0}**********************************", Thread.CurrentThread.ManagedThreadId);            List
threadList = new List
(); for (int i = 0; i < 5; i++) { string name = string.Format("btnThread_Click_{0}", i); ThreadStart method = () => TestThread(name); Thread thread = new Thread(method);//1 默认前台线程:程序退出后,计算任务会继续 thread.IsBackground = true;//2 后台线程:程序退出,计算立即结束 thread.Start();//启动线程 threadList.Add(thread);//添加在集合 } foreach (Thread thread in threadList) { thread.Join();///等待每个线程执行完毕 } watch.Stop();//结束计算时间 Console.WriteLine("**********************btnThread_Click End 主线程id {0} {1}************************************", Thread.CurrentThread.ManagedThreadId, watch.ElapsedMilliseconds); Console.WriteLine();

线程池(ThreadPool)

可设置线程池线程数量,把线程留在程序中

每次可循环使用,不用再去和操作系统申请线程

//线程池            ManualResetEvent mre = new ManualResetEvent(false);            for (int i = 0; i < 5; i++)            {                string name = string.Format("ThreadPool{0}", i);                WaitCallback method = t => {                    Console.WriteLine("我是异步调用方法参数:{0}", t.ToString());                    mre.Set(); //打开 mre.Reset();//关闭                };                ThreadPool.QueueUserWorkItem(method, name);            }            Console.WriteLine("我们来干点别的。。。。");            Console.WriteLine("我们来干点别的。。。。");            Console.WriteLine("我们来干点别的。。。。");            Console.WriteLine("我们来干点别的。。。。");            mre.WaitOne();//判断线程是否全部执行完成            ThreadPool.SetMaxThreads(8, 8);//设置最大线程池数量和IO线程池运行数量            ThreadPool.SetMinThreads(8, 8);            int workerThreads;            int ioThreads;            ThreadPool.GetMaxThreads(out workerThreads, out ioThreads);//获取当前线程状况

Task

CRL4.0

引用 Task是基于线程池开发,效率提升

//Task CRL4.0引用 Task是基于线程池开发,效率提升            {                TaskFactory taskFactory = new TaskFactory();//创建Task工厂                for (int i = 0; i < 5; i++)                {                    string name = string.Format("Async_{0}", i);                    Action act = () => TestThread(name);//这个方法执行动作:耗时而已                    Task task = taskFactory.StartNew(act);//这里也可以 Task task =new Task(act);                    task.Start();//启动Task                }            }            //Task一下方法比较效率高推荐使用            {                TaskFactory taskFactory = new TaskFactory();//创建Task工厂                List
taskList = new List
();//创建Task集合 Action
act = o => Console.WriteLine(o.ToString()); Task task = taskFactory.StartNew(act, "参数1");//创建一个新的委托Task方法 taskList.Add(task); taskList.Add( taskFactory.StartNew(s => Console.WriteLine(s.ToString()), "参数2")); Task any = taskFactory.ContinueWhenAny(taskList.ToArray(), t =>//taskList中任意任务线程执行完毕,就执行该方法(异步执行) { //t.AsyncState Console.WriteLine("这里是ContinueWhenAny {0}", Thread.CurrentThread.ManagedThreadId);//打印线程ID }); Task all = taskFactory.ContinueWhenAll(taskList.ToArray(), tList =>//taskList中全部任务线程执行完毕,就执行该方法(异步执行) { Console.WriteLine("这里是ContinueWhenAll {0}", Thread.CurrentThread.ManagedThreadId); }); Task.WaitAny(taskList.ToArray());//执行的线程等待某一个task的完成 Task.WaitAll(taskList.ToArray());//执行的线程等待全部的task的完成 }

Parallel 并行计算

Parallel是基于Task开发,并行计算与Task.WaitAll执行等待结果不同的是:Task.WaitAll在执行时主线程在锁死等在子线程执行完成
Parallel是主线程也同样随机分配一个子线程去执行任务,Parallel比Task少开启一个线程

//Parallel 并行计算             Parallel.Invoke(() => TestThread("btnParallel_Click_0")//这个方法执行动作:耗时而已                          , () => TestThread("btnParallel_Click_1")//这个方法执行动作:耗时而已                          , () => TestThread("btnParallel_Click_2")//这个方法执行动作:耗时而已                          , () => TestThread("btnParallel_Click_3")//这个方法执行动作:耗时而已                          , () => TestThread("btnParallel_Click_4"));//这个方法执行动作:耗时而已            //等于使用4个task,然后主线程同步invoke一个委托  然后主线程waitall            Parallel.For(6, 10, t =>            {                string name = string.Format("For btnParallel_Click_{0}", t);                TestThread(name);//这个方法执行动作:耗时而已            });            ParallelOptions parallelOptions = new ParallelOptions()            {                MaxDegreeOfParallelism = 5//实例所允许的最大并行度。            };            Parallel.For(6, 15, parallelOptions, (t, state) =>            {                string name = string.Format("btnParallel_Click_{0}", t);                TestThread(name);                state.Break();//退出单次循环                state.Stop();//退出全部的循环                return;            });

异常处理、线程取消、多线程的临时变量和线程安全lock

//异常处理、线程取消、多线程的临时变量和线程安全lock          CancellationTokenSource cts = new CancellationTokenSource();//线程取消专用实例                TaskFactory taskFactory = new TaskFactory();                List
taskList = new List
(); for (int i = 0; i < 20; i++) { Action
act = t => { try { if (t.ToString().Equals("10"))//模拟当i=10抛异常 { throw new Exception(string.Format("{0} 执行失败", t)); } if (!cts.IsCancellationRequested)//是否被取消 { Console.WriteLine("{0} 执行成功", t); } else { Console.WriteLine("{0} 被取消", t); } } catch (Exception ex) { cts.Cancel();// 传达取消请求。 Console.WriteLine("子线程异常 {0}", ex.Message); } }; taskFactory.StartNew(act, i); Task task = taskFactory.StartNew(act, i, cts.Token);//加上 cts.Token 如果被取消集合里面剩余的线程就不会启动了 taskList.Add(task); } Task.WaitAll(taskList.ToArray()); ///多线程的临时变量和线程安全lock ///每次实例新对象防止变量访问冲突 ///如果同时访问同一变量加上Lock ///private static object obj = new object(); ///lock (obj) ///{ /// 锁住啦 ///}

 

转载于:https://www.cnblogs.com/AnkerZhang/p/7195315.html

你可能感兴趣的文章
stm32f429i disc usb cdc vcp 虚拟串口 example project (CubeMX Hal)
查看>>
Robust PCA via Outlier Pursuit
查看>>
实战练习细节(分行/拼接字符串/字符串转int/weak和copy)
查看>>
wddm 部署问题解决
查看>>
Strict Standards: Only variables should be passed by reference
查看>>
Slab-based Intersection
查看>>
将输入流转为字符串工具类
查看>>
hiho_offer收割18_题解报告_差第四题
查看>>
高斯消元
查看>>
AngularJs表单验证
查看>>
regasm.exe 注册dll
查看>>
什么是死锁,简述死锁发生的四个必要条件,如何避免与预防死锁
查看>>
静态方法是否属于线程安全
查看>>
fegin 调用源码分析
查看>>
Linux的基本命令
查看>>
02号团队-团队任务3:每日立会(2018-12-05)
查看>>
sql 语法大全
查看>>
SQLite移植手记1
查看>>
Java AmericanFlagSort
查看>>
Mysql远程连接报错
查看>>