如何重构此ForEach..代码以使用Parallel.ForEach..？

如何解决如何重构此ForEach..代码以使用Parallel.ForEach..？

| 我有一个对象列表，希望将其从一个源复制到另一个源。有人建议我可以使用Parallel.ForEach加快速度 如何重构以下pseduo代码以利用

Parallel.ForEach(..)

？

var foos = GetFoos().ToList();
foreach(var foo in foos)
{
    CopyObjectFromOldBucketToNewBucket(foo,oldBucket,newBucket,accessKeyId,secretAccessKey);
}

“ 2”使用Amazon REST API将项目从一个存储桶移动到另一个存储桶。 干杯:)

解决方法

here3ѭ实际上并不是这里的最佳选择。 “ 3”将并行运行您的代码，但仍将为每个对AWS的请求使用线程池线程。相反，最好使用资源来代替

BeginCopyObject

方法。这不会耗尽等待响应的线程池线程，而只会在接收到响应并需要对其进行处理时才使用它。 这是有关如何使用Begin / End方法的简化示例。这些不是特定于AWS的，而是在整个.NET BCL中找到的一种模式。

public static CopyFoos() 
{
    var client = new AmazonS3Client(...);
    var foos = GetFoos().ToList();
    var asyncs = new List<IAsyncResult>();
    foreach(var foo in foos)
    {
        var request = new CopyObjectRequest { ... };  

        asyncs.Add(client.BeginCopyObject(request,EndCopy,client));
    }

    foreach(IAsyncResult ar in asyncs)
    {
        if (!ar.IsCompleted)
        {
            ar.AsyncWaitHandle.WaitOne();
        }
    }
}

private static EndCopy(IAsyncRequest ar) 
{    
    ((AmazonS3Client)ar.AsyncState).EndCopyObject(ar);
}

对于生产代码，您可能希望跟踪已发出的请求数量，并且一次只能发送有限数量的请求。测试或AWS文档可能会告诉您有多少并发请求是最佳的。 在这种情况下，当请求完成时我们实际上不需要执行任何操作，因此您可能会想跳过the7ѭ调用，但这会导致资源泄漏。每当调用BeginXxx时，都必须调用相应的EndXxx方法。,由于您的代码除了

foos

之外没有任何依赖关系，您可以简单地执行以下操作：

Parallel.ForEach(foos,( foo => 
{
    CopyObjectFromOldBucketToNewBucket(foo,oldBucket,newBucket,accessKeyId,secretAccessKey);
}));

但是请记住，在性能可能实际下降之后，I / O只能并行到一定程度。