1

我有一个按特定顺序排列的异步调用列表，哪个最先完成或最后一个完成都没有关系。所有这些异步任务都返回位图。所有异步任务都为一个返回单个位图接受，并返回位图列表列表。

出于测试目的，我能够更好地处理使用 Parallel 与 Task 的区别，我需要有人向我展示如何调用这些异步任务中的每一个，并设置一个包含所有返回异步列表的局部变量结果。

  1. 如何 Parallel.ForEach 这些任务
  2. 如何检索每个已完成任务的值并使用返回的结果设置一个局部变量。

---我只是一个接一个地等待每个任务的代码。

public async static Task<PdfSharp.Pdf.PdfDocument> RollUpDrawingsPDF(IElevation elevation)
{

    List<Bitmap> allSheets = new List<Bitmap>();

    var processedParts = new PartsProcessor.PartProcessor().ProcessParts(elevation);

    //elevation
    allSheets.Add(await ShopDrawing.Manager.GetElevationDrawing(elevation, true, RotateFlipType.Rotate90FlipNone));

    //door schedules, 3 schedules per sheet
    allSheets.AddRange(await ShopDrawing.Door.GetDoorSecheduleSheets(elevation, RotateFlipType.Rotate90FlipNone, 3));

    //materials list
    allSheets.Add(await MaterialsList.Manager.GetMaterialList(processedParts).GetDrawing());

    //optimized parts
    allSheets.Add(await Optimization.Manager.GetOptimizedParts(processedParts).GetDrawing());

    //cut sheet
    allSheets.Add(await CutSheet.Manager.GetCutSheet(processedParts).GetDrawing());

    return await PDFMaker.PDFManager.GetPDF(allSheets, true);
}

------代码我正在尝试在 Parallel.ForEach 中运行，但这不起作用，而是寻求帮助的起点。对于每个返回的任务结果，我需要设置该并行任务结果的 allSheets 的局部变量。

    public async static Task<PdfSharp.Pdf.PdfDocument> RollUpDrawingsPDF(IElevation elevation)
{

    List<Bitmap> allSheets = new List<Bitmap>();

    var processedParts = new PartsProcessor.PartProcessor().ProcessParts(elevation);

    Task[] myTask = new Task[5];
    myTask[0] = ShopDrawing.Manager.GetElevationDrawing(elevation, true, RotateFlipType.Rotate90FlipNone);
    myTask[1] = ShopDrawing.Door.GetDoorSecheduleSheets(elevation, RotateFlipType.Rotate90FlipNone, 3);
    myTask[2] = MaterialsList.Manager.GetMaterialList(processedParts).GetDrawing();
    myTask[3] = Optimization.Manager.GetOptimizedParts(processedParts).GetDrawing();
    myTask[4] = CutSheet.Manager.GetCutSheet(processedParts).GetDrawing();



    var x = Parallel.ForEach(myTask, t => t.Wait());

    ////elevation
    //allSheets.Add(await );

    ////door schedules, 3 schedules per sheet
    //allSheets.AddRange(await);

    ////materials list
    //allSheets.Add(await );

    ////optimized parts
    //allSheets.Add(await );

    ////cut sheet
    //allSheets.Add(await );

    return await PDFMaker.PDFManager.GetPDF(allSheets, true);
}

我将如何为这段代码实现 Parallel.ForEach？

*讨论代码示例。其他方法返回一个Bitmap时如何返回List *

async Task<Bitmap[]> RollUpHelper(IElevation elevation, PartsProcessor.ProcessedParts       processedParts)
            {
                return await Task<Bitmap[]>.WhenAll(

 ShopDrawing.Manager.GetElevationDrawing(elevation, true, RotateFlipType.Rotate90FlipNone),
                     //ShopDrawing.Door.GetDoorSecheduleSheets(elevation,RotateFlipType.Rotate90FlipNone, 3),
                     MaterialsList.Manager.GetMaterialList(processedParts).GetDrawing(),
                     MaterialsList.Manager.GetMaterialList(processedParts).GetDrawing(),
                     CutSheet.Manager.GetCutSheet(processedParts).GetDrawing()
                      );

            }
4

2 回答 2

6

Parallel.ForEach()用于并行运行多个同步操作。

您想等待一些异步 Tasks 完成：

await Task.WhenAll(tasks);
于 2013-06-07T17:10:43.817 回答
0

扩展 SLaks 的答案：

Task.WhenAll()将返回它等待的任务返回的所有结果的数组，因此您无需自己管理。

这是我使用的示例，string而不是Bitmap您的示例。请注意其中一名工人如何不返回 aList<string>并且我将其转换为 aList<string>与一个项目，以使其与其他项目具有相同的类型。

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading;
    using System.Threading.Tasks;

    namespace Demo
    {
        class Data
        {
            public string Value;
            public Data(string value) { Value = value; }
        }

        class Program
        {
            async Task<List<string>[]>  RunAsync()
            {
                return await Task.WhenAll
                (
                    Task.Factory.StartNew(() => 
                        new List<string> {Worker1(new Data("One"))}),

                    Task.Factory.StartNew(() => 
                        Worker2(new Data("Two"))),

                    Task.Factory.StartNew(() => 
                        Worker3(new Data("Three")))
                );

            }

            void Run()
            {
                var results = RunAsync().Result;

                // Now results is an array of List<string>, so we can iterate the results.

                foreach (var result in results)
                {
                    result.Print();
                    Console.WriteLine("--------------");
                }
            }

            string Worker1(Data data)
            {
                Thread.Sleep(1000);
                return data.Value;
            }

            List<string> Worker2(Data data)
            {
                Thread.Sleep(1500);
                return Enumerable.Repeat(data.Value, 2).ToList();
            }

            List<string> Worker3(Data data)
            {
                Thread.Sleep(2000);
                return Enumerable.Repeat(data.Value, 3).ToList();
            }

            static void Main()
            {
                new Program().Run();
            }
        }

        static class DemoUtil
        {
            public static void Print(this object self)
            {
                Console.WriteLine(self);
            }

            public static void Print(this string self)
            {
                Console.WriteLine(self);
            }

            public static void Print<T>(this IEnumerable<T> self)
            {
                foreach (var item in self)
                    Console.WriteLine(item);
            }
        }
    }
于 2013-06-07T18:21:07.040 回答