【转】1.DThread、ThreadPool、Task、Parallel的基本用法、区别以及弊端
多线程的操作在程序中也是比较常见的,比如开启一个线程执行一些比较耗时的操作(IO操作),而主线程继续执行当前操作,不会造成主线程阻塞。线程又分为前台线程和后台线程,区别是:整个程序必须要运行完前台线程才会退出,而后台线程会在程序退出的时候结束掉。Thread默认创建的是前台线程,而ThreadPool和Task默认创建的是后台线程,Thread可以通过设置 IsBackground 属性将线程设置为后台线程。
static void Main(string[] args)
{Thread thread = new Thread(new ThreadStart(NoParameterMethod));thread.Start();Console.WriteLine("程序已经执行完成");
}static void NoParameterMethod()
{Thread.Sleep(1000);Console.WriteLine("NoParameterMethod");
}
效果:
static void Main(string[] args)
{Thread thread = new Thread(new ThreadStart(NoParameterMethod)){IsBackground = true};thread.Start();Console.WriteLine("程序已经执行完成");
}static void NoParameterMethod()
{Thread.Sleep(1000);Console.WriteLine("NoParameterMethod");
}
效果:
下面来说一下几种开启多线程的方法:
1、Thread
1.1 开启一个线程,执行一个不带参数的方法
static void Main(string[] args)
{Thread thread = new Thread(new ThreadStart(NoParameterMethod));//注意Start开启线程之后,当前线程不是说一定会立马执行//而是说当前线程已经准备好被CPU调用,至于CPU什么时候调用是需要看情况而定thread.Start();Console.WriteLine("程序已经执行完成");
}static void NoParameterMethod()
{//使当前线程停止1sThread.Sleep(1000);Console.WriteLine("NoParameterMethod");
}
1.2开启一个线程,执行带参数的方法
static void Main(string[] args)
{Thread thread = new Thread(new ParameterizedThreadStart(ParameterMethod));//要传入的参数在Start的时候传入thread.Start("ParameterMethod");Console.WriteLine("程序已经执行完成");
}
//参数类型必须为Object类型,方法只能有一个参数
//如果想传入多个参数,可已将参数封装进入一个类中
static void ParameterMethod(Object x) {Thread.Sleep(1000);Console.WriteLine(x);
}
2、ThreadPool
使用ThreadPool开启一个线程
//无参 Thread.CurrentThread.ManagedThreadId是当前线程的唯一标识符
ThreadPool.QueueUserWorkItem(new WaitCallback(obj => Console.WriteLine(Thread.CurrentThread.ManagedThreadId)));
//有参
ThreadPool.QueueUserWorkItem(new WaitCallback(obj => Console.WriteLine(Thread.CurrentThread.ManagedThreadId)), "参数");
ThreadPool是Thread的一个升级版,ThreadPool是从线程池中获取线程,如果线程池中又空闲的元素,则直接调用,如果没有才会创建,而Thread则是会一直创建新的线程,要知道开启一个线程就算什么事都不做也会消耗大约1m的内存,是非常浪费性能的,接下来我们写一个例子来看一下二者的区别:
#region 使用Thread开启100个线程
for (int i = 0; i < 100; i++)
{(new Thread(new ThreadStart(() => Console.WriteLine(Thread.CurrentThread.ManagedThreadId)))).Start();
}
#endregion
运行结果:
我们可以看到每一个主线程表示id都是不同的,也就是说使用Thread开启线程每次都是新创建一个
#region 使用ThreadPool开启100个线程
for (int i = 0; i < 100; i++)
{ThreadPool.QueueUserWorkItem(new WaitCallback(obj => Console.WriteLine(Thread.CurrentThread.ManagedThreadId)));
}
#endregion
运行结果:
相信区别已经很明显了,这里我再说一下,线程池中一开始是没有一个线程的,使用ThreadPool开启一个线程之后,线程执行完毕,会加入到线程池中,后续需要再次开启线程的时候查看线程池中有没有空闲的线程,有则调用,没有则创建,如此循环
二者之间还有一个区别,就是ThreadPool可以操控线程的状态,比如等待线程完成,或者终止超时子线程操作
取消子线程操作
CancellationTokenSource cts = new CancellationTokenSource();
ThreadPool.QueueUserWorkItem(new WaitCallback(CanCancelMethod),cts.Token);
cts.Cancel();
Console.ReadKey();
static void CanCancelMethod(Object obj) {CancellationToken ct = (CancellationToken)obj;if (ct.IsCancellationRequested) {Console.WriteLine("该线程已取消");}//就算ct.IsCancellationRequested为真,接下来的代码还是会执行//因为该方法并没有ruturnThread.Sleep(1000);Console.WriteLine($"子线程{Thread.CurrentThread.ManagedThreadId}结束");
}
感觉这个取消子线程的方法和设置一个全局变量,然后通过判断和更改全局变量的值,设置线程是否取消的效果一样
ThreadPool的其他操作感兴趣的可以自己搜索学一下,因为终止线程什么操作都是比较麻烦的,关于ThreadPool就不再多说了
3、Task
Task和ThreadPool是一样的,都是从线程池中取空闲的线程
使用Task开启一个线程
//方法1 使用Task的Run方法
Task.Run(()=> {Console.WriteLine($"线程{Thread.CurrentThread.ManagedThreadId}已开启");
});
//方法2 使用Task工厂类TaskFactory对象的StartNew方法
(new TaskFactory()).StartNew(() =>
{Console.WriteLine($"线程{Thread.CurrentThread.ManagedThreadId}已开启");
});
Run和StartNew方法都是返回一个Task类型的对象,代表当前开启的线程,如果方法有返回值
//如果方法有返回值
Task<int> t1 = Task.Run<int>(() => {return 1;
});
//通过t1.Result查看返回的结果
Console.WriteLine(t1.Result);
取消线程操作的话和ThreadPool取消线程操作一样
//1s后自动取消线程
CancellationTokenSource cts = new CancellationTokenSource(1000);
//为取消线程注册回调函数
cts.Token.Register(()=> {Console.WriteLine("线程已取消");
});Task.Run(()=> {Console.WriteLine("开始执行");Thread.Sleep(2000);//判断当前线程是否已被取消if (cts.Token.IsCancellationRequested) {Console.WriteLine("方法已结束");return;}Console.WriteLine("线程继续执行");
},cts.Token);
等待所有线程执行完毕
//存放所有线程
List<Task> lst = new List<Task>();
//开启10个线程
for (int i = 0;i < 10;i++) {lst.Add(Task.Run(()=> {Thread.Sleep(new Random().Next(1,3000));Console.WriteLine($"线程{Thread.CurrentThread.ManagedThreadId}");}));
}
//等待所有线程执行完毕
Task.WaitAll(lst.ToArray());
Console.WriteLine("所有线程执行完毕");
等待任意一个先线程执行完毕
//存放所有线程
List<Task> lst = new List<Task>();
//开启10个线程
for (int i = 0;i < 10;i++) {lst.Add(Task.Run(()=> {Thread.Sleep(new Random().Next(1,3000));Console.WriteLine($"线程{Thread.CurrentThread.ManagedThreadId}");}));
}
//等待任意线程执行完毕
Task.WaitAny(lst.ToArray());
Console.WriteLine("已有现成执行完毕");
对于Thread、ThreadPool和Task,如果要用多线程的话,优先使用Task,如果版本不支持Task,则考虑ThreadPool
4、Parallel
Parallel循环开启多线程,并行任务,对于多线程开启任务,开启的顺序都是不确定的
Parallel.Invoke()
Action[] action = new Action[] {()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),
};
Parallel.Invoke(action);
相当于
Action[] action = new Action[] {()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),
};
for (int i = 0; i < action.Length; i++)
{Task.Run(action[i]);
}
Invoke时也可以进行一些配置,例如配置线程池中只能最多保持一个线程
Action[] action = new Action[] {()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),()=>Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}"),
};
Parallel.Invoke(new ParallelOptions()
{MaxDegreeOfParallelism = 1
}, action);
运行结果:
Parallel.For()
//将迭代的结果保存起来
ParallelLoopResult plr = Parallel.For(1, 10, (i) =>
{Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}");
});
Console.WriteLine(plr.IsCompleted);
相当于
for (int i = 1; i < 10; i++)
{Task.Run(() =>{Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}");});
}
相对于循环Task.Run()更加简洁
Parallel.ForEach()
方法和foreach类似,不过是采用的是异步方式遍历,要想被Parallel.ForEach()必须实现IEnumerable接口
Parallel.ForEach<String>(new List<String>() {"a","b","c","d","e","f","g","h","i"
}, (str) =>
{Console.WriteLine(str);
});
运行结果:
停止循环的方法
//将迭代的结果保存起来
ParallelLoopResult plr = Parallel.For(1, 10, (i,state) =>
{Console.WriteLine($"线程:{Thread.CurrentThread.ManagedThreadId}");if (i==4) {//结束state.Break();}
});
Console.WriteLine(plr.IsCompleted);
【转】1.DThread、ThreadPool、Task、Parallel的基本用法、区别以及弊端相关推荐
- C#并行开发_Thread/ThreadPool, Task/TaskFactory, Parallel
大家好,本次讨论的是C#中的并行开发,给力吧,随着并行的概念深入,哥也赶上这个潮流了,其实之前讨论C#的异步调用或者C#中BeginInvoke或者Invoke都已经涉及了部分本篇的内容. 参考书目: ...
- c#进阶(1)—— Task Parallel Library 并行执行与串行执行
本文参考的博文出处:http://www.cnblogs.com/stoneniqiu/p/4857021.html 总体说明: (1).理解硬件线程和软件线程 硬件线程也称为逻辑内核,一个物理内核可 ...
- Task.Factory.StartNewTResult 和 Task.RunTResult 到底有什么区别?
前言 这不是和<Task.Factory.StartNew 和 Task.Run 到底有什么区别?>一样吗,怎么又写一篇? 起先我也是这么觉得的,但实际发现并非如此. 实现代码 查看这 2 ...
- Task/Parallel实现异步多线程
代码: #region Task 异步多线程,Task是基于ThreadPool实现的{//TestClass testClass = new TestClass();//Action<obje ...
- Task.Factory.StartNew 和 Task.Factory.FromAsync 有什么区别?
咨询区 soleiljy 假设我们有一个涉及IO操作的方法 (读取数据库),这个方法支持以同步或者异步的方式执行. 同步方式 IOMethod() 异步方式 BeginIOMethod() EndI ...
- Task.Factory.StartNew 和 Task.Run 到底有什么区别?
前言 Task.Factory.StartNew 和 Task.Run 都可以创建 Task: Task.Factory.StartNew(() => { Console.WriteLine(& ...
- 针对于多线程概念的理解
今天是2月28日,本来的想法是每月一两篇,但是时间有点太匆忙,在这里也想向大家说一说,时间很少,愿各位好好珍惜,今天谈一谈多线程,如同其文字描述一样,线程很多,这也是多线程存在的原因,那首先什么是多线 ...
- TPL中Task执行的内联性线程重入
在没有 TPL(Task Parallel Library)之前,使用 ThreadPool 处理多线程事务及等待,可能类似如下代码: 1 class Program 2 { 3 [ThreadSta ...
- C#中的thread和task之Task
简介 Task是在.NET Framework 4中添加进来的,这是新的namespace:System.Threading.Tasks;它强调的是adding parallelism and con ...
最新文章
- WorkFlow For Net ! NET 平台工作流 或 BPM
- hive桌游中文规则_超火爆轻策桌游《小小城镇》新扩展——小金币大作为,邀你共筑繁荣小镇!...
- 简单学习kali高级渗透测试思路方法
- python 判断时间是否大于6点_48 python判断时间是否落在两个时区之间(只比较时刻不比较日期)...
- c++ ptree判断是否存在节点_CTreeCtrl 查找 等于某值 的节点,并设置为高亮
- java 酒店预定 app_Android应用源码酒店在线预定app项目全套
- 创业的一些挫见之第二家公司失败记录
- Dao层抽取BaseDao公共方法
- Spring Boot 消息
- 求解偏微分方程开源有限元软件deal.II学习--Step 5
- mysql join 去重_对mysql left join 出现的重复结果去重
- Nacos配置热更新的4种方式、读取项目配置文件的多种方式,@value,@RefreshScope,@NacosConfigurationProperties
- c语言 设置线程优先级,C# Priority:多线程优先级设置
- JAVA实现PDF合并、拆分代码工具类
- 2022-2028全球粉尘检测仪行业调研及趋势分析报告
- 宏定义是什么?为什么要进行宏定义?宏定义的格式
- CSS动画实现星星闪烁效果
- LWIP应用开发|DNS域名解析
- 程序员公司实行996,加班费却只有10块!网友:我们20块
- 利用西瓜播放器(xgplayer)实现直播点播