如何重构此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只能并行到一定程度。

要回复问题请先登录注册