如何重构此ForEach（..）代码以使用Parallel.ForEach（..）？
|
我有一个对象列表，希望将其从一个源复制到另一个源。有人建议我可以使用Parallel.ForEach加快速度
如何重构以下pseduo代码以利用
Parallel.ForEach(..)
var foos = GetFoos().ToList();
foreach(var foo in foos)
{
CopyObjectFromOldBucketToNewBucket(foo, oldBucket, newBucket,
accessKeyId, secretAccessKey);
}
没有找到相关结果
已邀请:
2 个回复
碧肮械淌设
方法。这不会耗尽等待响应的线程池线程，而只会在接收到响应并需要对其进行处理时才使用它。 这是有关如何使用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); }惜堡沁戚
之外没有任何依赖关系，您可以简单地执行以下操作：Parallel.ForEach(foos, ( foo => { CopyObjectFromOldBucketToNewBucket(foo, oldBucket, newBucket, accessKeyId, secretAccessKey); }));