C#并行庫Parallel類怎么使用

本篇內(nèi)容主要講解“C#并行庫Parallel類怎么使用”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“C#并行庫Parallel類怎么使用”吧!

Parallel.Invoke

這個函數(shù)的功能和Task有些相似，就是并發(fā)執(zhí)行一系列任務(wù)，然后等待所有完成。和Task比起來，省略了Task.WaitAll這一步，自然也缺少了Task的相關(guān)管理功能。它有兩種形式:

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

第二種方式可以自定義一個TaskManager對任務(wù)的執(zhí)行線程進(jìn)行管理（第一種方式用的是默認(rèn)的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);
}

輸出結(jié)果如下：

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

可見，由于第二次指定了最多只能使用兩個線程來執(zhí)行，故只有兩個Task并發(fā)執(zhí)行。

Parallel.ForEach和Parallel.For

Parallel.ForEach和Parallel.For用得要更加廣泛一些，他可以根據(jù)一個數(shù)據(jù)源來生成一些任務(wù)（Parallel.Invoke需要事先生成這些任務(wù)），同時并發(fā)執(zhí)行這些任務(wù)。基本示例如下：

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]));
}

這兩個函數(shù)都有多種重載形式，提供了許多控制功能，由于用得不是很多，這里就不一一介紹了。但有一點(diǎn)不是很好：如果需要用TaskManager的話，不得不用那最復(fù)雜的那一種形式。希望最終版本的時候會提供更合理的重載形式，畢竟TaskManager還是很常用的（雖然目前的TaskManager功能薄弱了點(diǎn)），而那些復(fù)雜的參數(shù)不是很常用的。因此，這里提供了兩個常用的擴(kuò)展方法的封裝：

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);
        }
    }
}

通過擴(kuò)展方法的方式用起來還是比較方便的。

到此，相信大家對“C#并行庫Parallel類怎么使用”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！