文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

C#并行库Parallel类怎么使用

2023-07-02 09:56

关注

本篇内容主要讲解“C#并行库Parallel类怎么使用”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“C#并行库Parallel类怎么使用”吧!

Parallel.Invoke

这个函数的功能和Task有些相似,就是并发执行一系列任务,然后等待所有完成。和Task比起来,省略了Task.WaitAll这一步,自然也缺少了Task的相关管理功能。它有两种形式:

Parallel.Invoke( params Action[] actions);Parallel.Invoke(Action[] actions,TaskManager manager,TaskCreationOptions options);

第二种方式可以自定义一个TaskManager对任务的执行线程进行管理(第一种方式用的是默认的TaskManager.Default)。

示例如下:

static void Main(string[] args){    var actions = new Action[]{        () => ActionTest("test 1"),        () => ActionTest("test 2"),        () => ActionTest("test 3"),        () => ActionTest("test 4")};    Console.WriteLine("Parallel.Invoke 1 Test");    Parallel.Invoke(actions);    Console.WriteLine();    Console.WriteLine("Parallel.Invoke 2 Test");    Parallel.Invoke(actions, new TaskManager(new TaskManagerPolicy(1, 1, 2)), TaskCreationOptions.None);}static void ActionTest(object value){    Console.WriteLine(">>> thread:{0}, value:{1}",    Thread.CurrentThread.ManagedThreadId, value);}

输出结果如下:

Parallel.Invoke 1 Test
>>> thread:3, value:test 1
>>> thread:3, value:test 2
>>> thread:4, value:test 3
>>> thread:5, value:test 4

Parallel.Invoke 2 Test
>>> thread:7, value:test 1
>>> thread:7, value:test 2
>>> thread:8, value:test 3
>>> thread:7, value:test 4

可见,由于第二次指定了最多只能使用两个线程来执行,故只有两个Task并发执行。

Parallel.ForEach和Parallel.For

Parallel.ForEach和Parallel.For用得要更加广泛一些,他可以根据一个数据源来生成一些任务(Parallel.Invoke需要事先生成这些任务),同时并发执行这些任务。基本示例如下:

static void Main(string[] args){    var data = new object[] { "test 1", "test 2", "test 3" };    Console.WriteLine("Parallel.ForEach Test");    Parallel.ForEach(data, item => ActionTest(item));    Console.WriteLine();    Console.WriteLine("Parallel.For Test");    Parallel.For(0, data.Length, index => ActionTest(data[index]));}

这两个函数都有多种重载形式,提供了许多控制功能,由于用得不是很多,这里就不一一介绍了。但有一点不是很好:如果需要用TaskManager的话,不得不用那最复杂的那一种形式。希望最终版本的时候会提供更合理的重载形式,毕竟TaskManager还是很常用的(虽然目前的TaskManager功能薄弱了点),而那些复杂的参数不是很常用的。因此,这里提供了两个常用的扩展方法的封装:

public static class ParallelExtend{    public static void ParallelForEach<T>(this IEnumerable<T> source, Action<T> hanlder)    {        Parallel.ForEach(source, hanlder);    }    public static void ParallelForEach<T>(this IEnumerable<T> source, Action<T> hanlder, TaskManagerPolicy policy)    {        using (var manager = new TaskManager(policy))        {            Parallel.ForEach(source,                () => 0,                (item, index, state) => hanlder(item),                local => { },                manager,                TaskCreationOptions.None);        }    }}

通过扩展方法的方式用起来还是比较方便的。

到此,相信大家对“C#并行库Parallel类怎么使用”有了更深的了解,不妨来实际操作一番吧!这里是编程网网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯