栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > .Net

C#多线程之 Parallel

.Net 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

C#多线程之 Parallel

前言:
Parallel 是 .NetFramwwork 4.5 提供的功能,是对Task的进一步封装。

开启线程

Parallel是一个静态类,调用静态方法Invoke即可开启多个线程,Invoke方法接收Action委托的数组。
开启多线程会并行执行,直到开启的线程执行完毕,才会继续执行主线程,实现功能类似于Task.WaitAll()
即会阻塞主线程,解决方案见接下来分析。

Parallel.Invoke(
    () => Console.WriteLine("do something1"),
    () => Console.WriteLine("do something2"),
    () => Console.WriteLine("do something3"),
    () => Console.WriteLine("do something4")
    );
Console.WriteLine("main thread");
控制线程数量

Parallel实现了控制使用线程数量的功能,这在Task,ThreadPool,Thread中都没有实现。
Parallel.Invoke是一个重载方法,其中有一个接收两个参数:
第一个参数接收线程数量的配置,第二个参数是Action数组。
下例中,设置线程数量为3,开启的7个任务只会用到特定的三个线程

ParallelOptions parallelOptions = new ParallelOptions();
parallelOptions.MaxDegreeOfParallelism = 3;//设置线程数量

Parallel.Invoke(parallelOptions,
    () => Console.WriteLine("do something1"),
    () => Console.WriteLine("do something2"),
    () => Console.WriteLine("do something3"),
    () => Console.WriteLine("do something4"),
    () => Console.WriteLine("do something5"),
    () => Console.WriteLine("do something6"),
    () => Console.WriteLine("do something7")
    );

Console.WriteLine("main thread");
解决Parallel 阻塞主线程问题

思路:将Parallel包装一层,放置在一个Task中 即可。

Task.Run(() =>
{
    ParallelOptions parallelOptions = new ParallelOptions();
    parallelOptions.MaxDegreeOfParallelism = 3;//设置线程数量

    Parallel.Invoke(parallelOptions,
        () => Console.WriteLine("do something1"),
        () => Console.WriteLine("do something2"),
        () => Console.WriteLine("do something3"),
        () => Console.WriteLine("do something4"),
        () => Console.WriteLine("do something5"),
        () => Console.WriteLine("do something6"),
        () => Console.WriteLine("do something7")
        );

    Console.WriteLine("main thread");
});
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/955288.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号