首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

在C#中将几个Parallel.ForEach合并为一个

可以使用Task类的ContinueWith方法来实现。ContinueWith方法可以在一个任务完成后执行另一个任务。

下面是一个示例代码:

代码语言:csharp
复制
using System;
using System.Collections.Generic;
using System.Threading.Tasks;

class Program
{
    static void Main(string[] args)
    {
        List<int> numbers = new List<int> { 1, 2, 3, 4, 5 };

        Task<List<int>> task1 = Task.Run(() =>
        {
            List<int> results = new List<int>();
            Parallel.ForEach(numbers, number =>
            {
                // 执行任务1的操作
                results.Add(number * 2);
            });
            return results;
        });

        Task<List<int>> task2 = task1.ContinueWith(previousTask =>
        {
            List<int> results = previousTask.Result;
            Parallel.ForEach(numbers, number =>
            {
                // 执行任务2的操作
                results.Add(number * 3);
            });
            return results;
        });

        Task<List<int>> task3 = task2.ContinueWith(previousTask =>
        {
            List<int> results = previousTask.Result;
            Parallel.ForEach(numbers, number =>
            {
                // 执行任务3的操作
                results.Add(number * 4);
            });
            return results;
        });

        // 等待最后一个任务完成并获取结果
        List<int> finalResults = task3.Result;

        // 输出结果
        foreach (int result in finalResults)
        {
            Console.WriteLine(result);
        }
    }
}

在上面的示例中,我们首先创建了一个包含一些数字的列表。然后使用Parallel.ForEach方法在每个数字上执行一些操作,并将结果添加到一个结果列表中。

然后,我们使用Task类的ContinueWith方法将多个Parallel.ForEach合并为一个任务。每个ContinueWith方法都会在前一个任务完成后执行,并将前一个任务的结果作为参数传递给下一个任务。

最后,我们等待最后一个任务完成并获取结果,然后输出结果。

这个方法可以帮助我们将多个Parallel.ForEach合并为一个任务,从而提高代码的可读性和性能。

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

  • C#中Parallel类For、ForEach和Invoke使用介绍

    Parallel类提供了数据和任务的并行性; Paraller.For()方法类似于C#的for循环语句,也是多次执行一个任务。使用Paraller.For()方法,可以并行运行迭代,迭代的顺序没有定义。在For()方法中,前两个参数是固定的,这两个参数定义了循环的开头和结束。首先描述它的第一个方法For(int,int,Action<int>),前面两个参数代表循环的开头和介绍,第三个参数是个委托,整数参数是循环的迭代次数,该参数被传递给委托引用的方法。Paraller.For()方法的返回类型是ParallelLoopResult结构,它提供了循环是否结束的信息和最低迭代的索引(返回一个表示从中调用 Break 语句的最低迭代的整数)。

    03

    C#并发实战Parallel.ForEach使用

    前言:最近给客户开发一个伙食费计算系统,大概需要计算2000个人的伙食。需求是按照员工的预定报餐计划对消费记录进行检查,如有未报餐有刷卡或者有报餐没刷卡的要进行一定的金额扣减等一系列规则。一开始我的想法比较简单,直接用一个for循环搞定,统计结果倒是没问题,但是计算出来太慢了需要7,8分钟。这样系统服务是报超时错误的,让人觉得有点不太爽。由于时间也不多就就先提交给用户使用了,后面逻辑又增加了,计算时间变长,整个计算一遍居然要将近10分钟了。这个对用户来说是能接收的(原来自己手算需要好几天呢),但是我自己接受不了,于是就开始优化了,怎么优化呢,用多线程呗。

    01

    C# 多线程七之Parallel

    关于Parallel不想说太多,因为它是Task的语法糖,至少我是这么理解的,官方文档也是这么说的,它本身就是基本Task的.假设我们有一个集合,不管是什么集合,我们要遍历它,首先想到的是For(如何涉及到修改或者读可以用for)或者Foreach(如果单纯的读),但是它两是同步的去操作集合,但是使用Parallel的静态For或者Foreach那就可以让多个线程参与这个工作,这样就能充分的利用CPU,但是你需要考虑CPU上下文产生的性能消耗,以及Parallel本身的性能消耗,所以,这也能解释为什么,你的循环里面执行的是不耗时的操作,使用for或者foreach的速度比使用Parallel的要快,所以使用Parallel还是要慎重.而且使用Parallel还需要注意的一点就是,不能有多线程争用问题,就是你的循环体里面不能有操作静态资源的操作.如果真的需要,那你可以加锁,但是那就失去它的优势了.

    04
    领券