C#并行库Parallel类介绍

更新时间：2022年06月16日 11:23:48 作者：天方

这篇文章介绍了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类的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

C#中查找Dictionary中的重复值的方法
这篇文章主要介绍了C#中查找Dictionary中的重复值的方法，需要的朋友可以参考下
2015-09-09
c#构造ColorComboBox(颜色下拉框)
这篇文章主要介绍了c#构造ColorComboBox的代码分享，大家参考使用吧
2013-12-12
C#导出生成excel文件的方法小结(xml,html方式)
C#导出生成excel文件的方法小结(xml,html方式)。需要的朋友可以过来参考下，希望对大家有所帮助
2013-10-10
C#基本打印事件用法实例
这篇文章主要介绍了C#基本打印事件用法,实例分析了C#中print打印及DrawString文本字符串绘制等相关技巧,需要的朋友可以参考下
2015-06-06
关于C#反射你需要知道的
这篇文章主要介绍了C#反射的相关知识，文中讲解的非常详细，代码帮助大家更好的参考学习，感兴趣的朋友可以了解下
2020-06-06
C#调用Oracle存储过程的方法
这篇文章主要介绍了C#调用Oracle存储过程的方法,包含数据库及C#对应的调用代码,具有一定参考借鉴价值,需要的朋友可以参考下
2015-01-01
C#使用NPOI操作Excel工具类的实现
NPOI是POI项目的.NET迁移版本,使用NPOI可以在没有安装Office或者相应环境的机器上对Word或Excel文档进行读写操作,下面我们就来学习一下如何使用NPOI编写操作Excel的工具类吧
2023-11-11
C#分屏控件用法实例
这篇文章主要介绍了C#分屏控件用法实例,需要的朋友可以参考下
2014-08-08
C#操作Word打印的示例
这篇文章主要介绍了C#操作Word打印的示例，帮助大家利用c#打印文件，提高办公效率，感兴趣的朋友可以了解下
2020-10-10
深入理解C#之接口
这篇文章主要介绍了C#接口(Interface)用法,较为详细的分析了C#中接口的功能、实现及使用技巧,具有一定参考借鉴价值,需要的朋友可以参考下
2021-07-07