如何使用一个固定参数和集合中的另一个参数编写 Parallel.ForEach？

Question

我有一个像这样的 foreach 方法：

public void Initialize(ClassB fixed)
{
    foreach (ClassA item in itemCollection)
    {
        this.InitializeStock(fixed, item);
    }
}        

我想将 Parallel.ForEach 与此方法一起使用，但不确定如何做到这一点。我无法将固定参数设置为类属性，因为已经从另一个 Parallel.ForEach 调用了 Initialize 方法。

提前致谢。

Answer 1

目前还不清楚问题是什么。这应该没问题：

public void Initialize(ClassB fixed)
{
    Parallel.ForEach(itemCollection, item =>
    {
        this.InitializeStock(fixed, item);
    });
}

fixed 变量将被 lambda 表达式捕获，以便在调用 InitializeStock 时使用它。

编辑：如果你真的不想要 lambda 表达式：

private class ClassBHolder
{
    private readonly ClassB fixed;
    // Foo is the class which has the Initialize method
    private readonly Foo container;

    internal ClassBHolder(ClassB fixed, Foo container)
    {
        this.fixed = fixed;
        this.container = container;
    }

    internal void Execute(ClassA item)
    {
        container.InitializeStock(fixed, item);
    }
}

public void Initialize(ClassB fixed)
{
    ClassBHolder holder = new ClassBHolder(fixed, this);
    Parallel.ForEach(itemCollection, holder.Execute);
}

...但是实际上，你更愿意读哪一个？

Answer 2

在这里试试这个：

public void Initialize(ClassB fixed)
{
    Parallel.ForEach(itemCollection, new ParallelOptions() { MaxDegreeOfParallelism = 100 },
                (item, i, j) =>
                     {

                         this.InitializeStock(fixed, item);

                     });
}