C# 并行处理选项

Question

我试图让我的一部分代码并行运行，我试图在 c# 中使用 ThreadPool 以避免任何头痛，但似乎我对池的要求太多了，我的代码实际上运行速度较慢它！

下面的代码解释了我想要做什么，我有许多音频样本（取决于从 512->4096 的任何地方的缓冲区大小）需要插入、传播并从节点读取（从 n = 4 到 n = 16) 在延迟网络中。这必须在逐个样本的基础上发生，所以我唯一的优化选择是参与插入/传播/读取的部分，并对网络中存在的每个节点进行并行操作。此操作在每个游戏帧中调用一次，并且在游戏的整个生命周期中都是必需的。查看分析器，散射操作需要大量时间，因此它是一个很好的候选者（我已经完成了传统优化）。目前，我让线程池工作者在一个工作项中为所有节点执行工作，只是为了启动和运行，但可以稍后拆分工作。

我认为下面代码的问题是工作项插入线程池的频率，我还在某处读到线程需要一段时间才能启动，所以如果线程池创建更多，它不一定有帮助。是否有人对其他并行处理方法有任何建议，或者可以发现我的线程池实现的任何错误？

public void propagateNetwork() {

    int numSampsToConsume = Mathf.min(inSamples.Count,buffersize);

    for (int i = 0; i < numSampsToConsume; i++) {
        outVal = 0.0f;
        inVal = inSamples.Dequeue () * networkInScale;

        directDelay.write (inVal);
        directVal = directDelay.read ();
        directVal *= directAtt;

        for (j = 0; j < network.Count; j++) {
            outVal += network [j].getOutgoing ();
            network [j].inputIncoming (inVal);
        }

        ThreadPool.QueueUserWorkItem (scatteringThreadPoolWrapper);
        scatteringThreadDone.WaitOne ();

        outVal += directVal;
        outSamples.Enqueue (outVal);
    }
}

public void scatteringThreadPoolWrapper(object threadConext) {
    doScatteringForNodeRange (0, network.Count);
}

public void doScatteringForNodeRange(int min,int max) {
    for (int i = min; i < max; i++) {
        network[i].doScattering (doLateReflections);
    }
    scatteringThreadDone.Set ();
}

Answer 1

也许使用Parallel.for 会起作用？我在每个循环迭代中都设置了一些局部变量，但我不知道这些操作都在做什么，以及如果并行运行会如何导致问题。

public void propagateNetwork() {
    int numSampsToConsume = Mathf.min(inSamples.Count,buffersize);

    Parallel.for(0, numSampsToConsume, i => {
        var outVal = 0.0f;
        var inVal = inSamples.Dequeue () * networkInScale;

        directDelay.write (inVal);
        var directVal = directDelay.read ();
        directVal *= directAtt;

        Parallel.for(0, network.Count, j => {
            outVal += network [j].getOutgoing ();
            network [j].inputIncoming (inVal);
        });

        doScatteringForNodeRange (0, network.Count);

        outVal += directVal;
        outSamples.Enqueue (outVal);
    });
}