.NET多线程知识快速学习

多线程是一个不会过期的话题，由于每一个开发的成长必然要掌握这个知识点，不然半懂不懂怎么保证系统的可靠性和性能，其实在网上随便一搜都会有海量的文章说这个话题，大多数写得很细写得很是好，但发现不多有概览性的文章，我但愿能借本文给你们一个全局视野，结合多年实践帮你们快速学习或者回顾思考，对感兴趣的知识点再深刻学习了解。

1、知识点归纳

2、具体实例演示如何实现

> Thread 多线程最基础的类

//ThreadPool.GetMaxThreads(out int maxTCount, out int maxPCount);
//ThreadPool.GetMinThreads(out int minTCount, out int minPCount);
//ThreadPool.SetMaxThreads(maxTCount, maxPCount);// 调整最大线程数
//ThreadPool.SetMinThreads(minTCount, minPCount);// 调整最小线程数

long tick = C_ITEM_COUNT;
ManualResetEvent signal = new ManualResetEvent(false);
Console.WriteLine("========== 示例：采用Thread执行处理 ==========");
for (int i = 0; i < C_ITEM_COUNT; i++)
{
    new Thread((obj) =>
    {
        Thread.Sleep(500);
        Console.Write(" {0} ", obj);
        if (Interlocked.Decrement(ref tick) == 0)
            signal.Set();
    }).Start(i);
}
Console.Write(" 等待子线程执行 ");
signal.WaitOne();
Console.WriteLine();
Console.WriteLine("所有线程执行完毕，按任意键继续...");

> ThreadPool 线程池，XX池的概念能够普遍应用于其余资源管理，例如字体池(防句柄泄露)、短信猫池等等

tick = C_ITEM_COUNT;
signal.Reset();
Console.WriteLine();
Console.WriteLine("========== 示例：采用ThreadPool执行处理 ==========");
for (int i = 0; i < C_ITEM_COUNT; i++)
{
    ThreadPool.QueueUserWorkItem((obj) =>
    {
        Thread.Sleep(500);
        Console.Write(" {0} ", obj);
        if (Interlocked.Decrement(ref tick) == 0)
            signal.Set();
    }, i);
}
Console.Write(" 等待子线程执行 ");
signal.WaitOne();
Console.WriteLine();
Console.WriteLine("所有线程执行完毕，按任意键继续...");

> Task 任务，功能丰富用法灵活。结合现实生活用字面意思去理解就好：能够同时作多个任务，任务作完能够接着作其余任务，任务可能会取消等等。

tick = C_ITEM_COUNT;
signal.Reset();
Console.WriteLine();
Console.WriteLine("========== 示例：采用Task执行处理，注意取消了处理{0}的进程 ==========", C_ITEM_COUNT - 2);
var tasks = new Tuple<Task, CancellationTokenSource>[C_ITEM_COUNT];
for (int i = 0; i < C_ITEM_COUNT; i++)
{
    var cts = new CancellationTokenSource();
    var task = Task.Factory.StartNew((obj) =>
    {
        Thread.Sleep(500);
        Console.Write(" {0} ", obj);
    }, i, cts.Token);
    task.ContinueWith((t) =>
    {
        if (Interlocked.Decrement(ref tick) == 0)
            signal.Set();
    });
    tasks[i] = new Tuple<Task, CancellationTokenSource>(task, cts);
}

tasks[C_ITEM_COUNT - 2].Item2.Cancel();// 取消线程。

Console.Write(" 等待子线程执行 ");
signal.WaitOne();
Console.WriteLine();
Console.WriteLine("所有线程执行完毕，按任意键继续...");

> Parallel 并行

tick = C_ITEM_COUNT;
signal.Reset();
Console.WriteLine();
Console.WriteLine("========== 示例：采用Parallel执行处理 ==========");
Parallel.For(0, C_ITEM_COUNT, obj =>
{
    Thread.Sleep(500);
    Console.Write(" {0} ", obj);
    if (Interlocked.Decrement(ref tick) == 0)
        signal.Set();
});

Console.Write(" 等待子线程执行 ");
signal.WaitOne();
Console.WriteLine();
Console.WriteLine("所有线程执行完毕，按任意键继续...");

以上示例执行结果以下，重点能够关注下"等待子线程执行"这个节点，理解主线程和各子线程的优先执行顺序

3、性能对比（理解线程池技术的性能也能够经过最大最小线程数调节）

> 循环数：200，线程池参数：默认

> 循环数：200，线程池参数：50 - 1000

> 循环数200，线程池参数：100-1000

 

> 循环数200，线程池参数：200-1000

 

最大线程数 ~ 最小线程数	Thread(ms)	ThreadPool(ms)	Task(ms)	Parallel(ms)
2047/1000 ~ 12/12	2712.09	8057.14	8585.01	7526.57
1000/1000 ~ 50/50	2733.25	2289.96	2218.29	3660.33
1000/1000 ~ 100/100	2503.08	1620.73	1534.50	1742.78
1000/1000 ~ 200/200	2999.27	1436.24	1150.21	935.22

 4、结论

> Thread就像脱缰的野马，不受控制，建立多少就运行多少，可能少许时效率是高了，量大的时候除了性能没优点，还可能致使句柄泄露。

> ThreadPool与Task相似，但Task相比效率更高用法更灵活。

> Parallel自带了同步功能，不须要用信号量来作额外的同步等待。

> ThreadPool、Task、Parallel的性能都取决于线程池最大线程数和最小线程数。

> 推荐使用 Task 和 Parallel，具体用哪一个能够参考用法本身斟酌。