从线程池c#更新进度条

Question

我尝试使用多线程处理一些数据，其中我使用线程池生成等于内核数量的线程（仅限.NET 2.0 到 3.5，因此无法使用 TPL）。

我的所有线程都在数据的不同部分执行相同的函数。

我的问题是我无法从线程池的线程更新进度条。找到了诸如调用和后台工作程序之类的解决方案，但无法真正理解如何使用它们，请帮助我了解如何使用它们。

我的代码看起来

 private static float[] inpdat=new float[1000];//The input array to process
 //The spawned threads
 public void dowork(object o) 
 {
    int np = (int)o;
    for(int i=np;i<inpdat.length;i=i+Environment.ProcessorCount)
    {
         //do some processing
         if(np==0)
          {
              //update progress bar here
          }
    }
 }


    //The main thread
    for (int npou = 0; npou < numproc; npou++)
    {
        resetEvents[npou] = new ManualResetEvent(false);
        ThreadPool.QueueUserWorkItem(new WaitCallback(dowork), npou);
        PetrelLogger.InfoOutputWindow("manual reset event set");
    }

速度对我来说是最重要的，所以如果跨线程调用占用最少的时间将会非常有帮助。 谢谢

Answer 1

您可以通过更新用户控件（在您的情况下进度栏）来执行一些操作。
添加您的表单作为输入参数，或者为您的表单将实现的结果添加一些回调接口：

interface IMyCallback
{
    void Progress(int progress);
}

在表单实现中添加以下代码：

void Progress(int Progress)
{
    if(this.InvokeRequired)
    {
        this.BeginInvoke(new ParametrizedThreadStart(Inv_Progress), Progress);
    }
    else
    {
        Inv_Progress(Progress);
    }
}

void Inv_Progress(object obj)
{
    int progress = obj as int;
    // do your update progress bar work here

}

现在您可以执行以下操作：

public void dowork(object o) 
 {
    int np = (int)o;
    for(int i=np;i<inpdat.length;i=i+Environment.ProcessorCount)
    {
         //do some processing
         if(np==0)
          {
              myCallback.Progress(0);
          }
    }
 }

Answer 2

标准调用可能是最简单的，您可以使用匿名委托来使其更简洁。

int n = 5;
myProgressBar.Invoke(
    delegate
    {
        myProgressBar.Value = n;
    }
);

请记住，在某些情况下（例如，从一个线程内循环使用此委托），您可能需要声明一个委托并将值作为参数传递给它。如果不这样做，当地人可能会做出奇怪的行为。使用匿名方法和 Action 类也是如此。

Answer 3

这是一个例子：

ThreadPool.QueueUserWorkItem(new WaitCallback(o =>
    {
        // worker method implementation
        .....
        progressBar1.Invoke(new MethodInvoker(() => progressBar1.Value = 20));
    }));