0

我正在使用多个backgroundworker来执行通过网络连接的过程。根据 中的行数datagridview，它获取每一行的值并通过另一个执行长过程的类方法。这里我使用for循环来启动backgroundworker，所以问题是进程何时启动，基于计数datagridview更多backgroundworkers开始运行的行数。但我想限制这一点。例如，如果我有 50 行，我只想一次执行 5 个后台工作程序。在这 5 个完成任务后，接下来的 5 个必须开始。那么如何限制那些？

我使用了以下代码：

Backgroundworker bs;
private void button1_Click(object sender, EventArgs e)
{
  threadNumber = 0;
  threadRunning = 0;
  for(int i=0;i<datagridview1.Rows.Count;i++)
    {
       bs = new Backgroundworker();
       bs.DoWork += new DoWorkEventHandler(bs_DoWork);
       bs.RunWorkerCompleted += new RunWorkerCompletedEventHandler(bs_Completed);
       bs.WorkerSupportCancellation = true;
       bs.RunWorkerAsync(i);
    } 
}

private void bs_DoWork(object sender, DoWorkEventArgs e)
  {
    int i = (int)e.Argument;
    while(bs.CancellationPending !=true && threadNumber < datagridview1.Rows.Count)
     {
      lock (this)
        {
            for (int i = 0; i < Max_Threads - threadRunning; i++)
            {
                if (threadNumber < datagridview1.Rows.Count)
                {
                   Webmethod obj = new webmethod();
                   obj.Callmethod(i); // this takes long time to perform
                   threadNumber +=1;
                   threadRunning +=1;
                 }
              }
          }
 }
 }

但是当我开始这个过程时，所有的后台工作人员都开始了这个任务。任何人都可以帮助我吗？

提前致谢..

4

1 回答 1

2

你想要做什么并不完全清楚。您的 click 方法BackgroundWorker为每个数据行启动一个新的，但随后您的DoWork处理程序也为每一行执行内部循环。非常混乱。我认为您想要的是启动Max_Threads工人，并让他们合作处理行。

您在增加threadNumber. 增量不是原子操作，因此有可能两个线程同时递增它最终会相互踩踏。您可能需要使用Interlocked.Increment来同步对它的访问。

我想你想要做的是：

int threadNumber;
private void button1_Click(object sender, EventArgs e)
{
    threadNumber = -1;
    // Start Max_Threads workers
    for(int i=0; i<Max_Threads; i++)
    {
        var bs = new Backgroundworker();
        bs.DoWork += new DoWorkEventHandler(bs_DoWork);
        bs.RunWorkerCompleted += new RunWorkerCompletedEventHandler(bs_Completed);
        bs.WorkerSupportCancellation = true;
        bs.RunWorkerAsync();
    } 
}

private void bs_DoWork(object sender, DoWorkEventArgs e)
{
    // Process items until cancellation requested, or until end of list
    while(!bs.CancellationPending)
    {
        int rowNumber = Interlocked.Increment(ref threadNumber);
        if (rowNumber >= datagridview1.Rows.Count)
        {
             break;
        }
        Webmethod obj = new webmethod();
        obj.Callmethod(rowNumber); // this takes long time to perform
    }
}
于 2013-10-14T15:45:50.107 回答