C#/.NET Thread类实现线程等待，回调，多线程并发操作 |
您所在的位置：网站首页 › 等待线程结束的函数 › C#/.NET Thread类实现线程等待，回调，多线程并发操作 |
|
点击此进入C#/.NET异步编程【目录】
Thread是C#语言对线程对象的封装 ，它从.NET1.0版本就开始存在了，属于元老级的类了。 下面我用代码使用Thread类实现线程等待，回调，前台线程/后台线程首先我们需要先定义一个比较消耗资源的方法用来跑线程 /// /// 一个比较耗时耗资源的私有方法 /// /// private void DoSomethingLong(string name) { Console.WriteLine($"****************DoSomethingLong {name} Start {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************"); long lResult = 0; for (int i = 0; i thread.Abort();//销毁，方式是抛异常 也不建议 不一定及时/有些动作发出收不回来 } catch (Exception) { Thread.ResetAbort();//取消Abort异常 } //3、线程等待 thread.Join(500);//最多等500 Console.WriteLine("等待500ms"); thread.Join();//当前线程等待thread完成 //4、判断线程是否停止 while (thread.ThreadState != ThreadState.Stopped) { Thread.Sleep(100);//当前线程 休息100ms } //5、设置后台线程 //默认是前台线程，启动之后一定要完成任务的，阻止进程退出 thread.IsBackground = true;//指定后台线程：随着进程退出 //6、设置线程优先级 thread.Priority = ThreadPriority.Highest;//线程优先级 //CPU会优先执行 Highest 不代表说Highest就最先 前台线程跟后台线程的区别：Thread默认是前台线程，启动之后一定要完成任务的，阻止进程退出，就是一定要线程运行完毕进程才会退出。 而后台线程则随着进程的退出线程也跟着退出。 Thread的前台多线程并发 /// /// Thread前台多线程并发 /// private void ForegroundThreads() { Console.WriteLine($"****************开始前台多线程并发 {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************"); for (int i = 0; i Console.WriteLine($"***************开始后台多线程并发 {Thread.CurrentThread.ManagedThreadId.ToString("00")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************"); for (int i = 0; i Thread thread = new Thread(() => { act.Invoke(); callback.Invoke(); }); thread.Start(); } // Thread线程回调委托 private void UseThreadCallback() { this.ThreadWithCallback(() => Console.WriteLine($"这里是主线程执行 {Thread.CurrentThread.ManagedThreadId.ToString("00")}") , () => Console.WriteLine($"这里是回调执行 {Thread.CurrentThread.ManagedThreadId.ToString("00")}")); } Thread的带返回值的异步调用 /// /// 又要结果 要不阻塞 /// /// /// /// private Func ThreadWithReturn(Func func) { T t = default(T); Thread thread = new Thread(() => { t = func.Invoke(); }); thread.Start(); return () => { thread.Join(); return t; }; } //带返回的异步调用 需要获取返回值 private int UseThreadReturn() { Func func = this.ThreadWithReturn(() => { Thread.Sleep(2000); return DateTime.Now.Millisecond; }); return func.Invoke(); } |
今日新闻 |
点击排行 |
|
推荐新闻 |
图片新闻 |
|
专题文章 |
| CopyRight 2018-2019 实验室设备网 版权所有 win10的实时保护怎么永久关闭 |