C＃多个BackgroundWorkers

Question

我正在尝试设置多个BackgroundWorkers来做工作，当不忙的时候开始做下一部分工作。我似乎无法让他们正常工作。我有以下代码。

当我将FilesToProcess设置为等于或小于MaxThreads时，它可以完美地工作，但如果我将其设置得更高，应用程序会冻结。

我确信它很简单，但我看不到它。

using System;
using System.ComponentModel;
using System.Threading;
using System.Windows.Forms;

namespace bgwtest
{
    public partial class Form1 : Form
    {
        private const int MaxThreads = 20;
        private const int FilesToProcess = 21;
        private BackgroundWorker[] threadArray = new BackgroundWorker[MaxThreads];

        public Form1()
        {
            InitializeComponent();
        }

        private void Form1Load(object sender, EventArgs e)
        {
            InitializeBackgoundWorkers();
        }

        private void InitializeBackgoundWorkers()
        {
            for (var f = 0; f < MaxThreads; f++)
            {
                threadArray[f] = new BackgroundWorker();
                threadArray[f].DoWork += new DoWorkEventHandler(BackgroundWorkerFilesDoWork);
                threadArray[f].RunWorkerCompleted += new RunWorkerCompletedEventHandler(BackgroundWorkerFilesRunWorkerCompleted);
                threadArray[f].WorkerReportsProgress = true;
                threadArray[f].WorkerSupportsCancellation = true;
            }
        }

        private void button1_Click(object sender, EventArgs e)
        {
            for (var f = 0; f < FilesToProcess; f++)
            {
                var fileProcessed = false;
                while (!fileProcessed)
                {
                    for (var threadNum = 0; threadNum < MaxThreads; threadNum++)
                    {
                        if (!threadArray[threadNum].IsBusy)
                        {
                            Console.WriteLine("Starting Thread: {0}", threadNum);

                            threadArray[threadNum].RunWorkerAsync(f);
                            fileProcessed = true;
                            break;
                        }
                    }
                    if (!fileProcessed)
                    {
                        Thread.Sleep(50);
                    }
                }
            }
        }

        private void BackgroundWorkerFilesDoWork(object sender, DoWorkEventArgs e)
        {
            ProcessFile((int)e.Argument);

            e.Result = (int)e.Argument;
        }

        private static void ProcessFile(int file)
        {
            Console.WriteLine("Processing File: {0}", file);
        }

        private void BackgroundWorkerFilesRunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
            if (e.Error != null)
            {
                MessageBox.Show(e.Error.Message);
            }

            Console.WriteLine("Processed File: {0}", (int)e.Result);
        }
    }
}

Answer 1

问题似乎是你的工人永远不会完成。为什么会这样，我不确定;它与你运行它们的方法（和线程）本身并没有完成这一事实有关。我能够通过创建另一个工作人员来将文件分配给worker数组来解决问题：

    private BackgroundWorker assignmentWorker;

    private void InitializeBackgoundWorkers() {
        assignmentWorker = new BackgroundWorker();
        assignmentWorker.DoWork += AssignmentWorkerOnDoWork;
        // ...
    }

    private void AssignmentWorkerOnDoWork( object sender, DoWorkEventArgs doWorkEventArgs ) {
        for( var f = 0; f < FilesToProcess; f++ ) {
            var fileProcessed = false;
            while( !fileProcessed ) {
                for( var threadNum = 0; threadNum < MaxThreads; threadNum++ ) {
                    if( !threadArray[threadNum].IsBusy ) {
                        Console.WriteLine( "Starting Thread: {0}", threadNum );

                        threadArray[threadNum].RunWorkerAsync( f );
                        fileProcessed = true;
                        break;
                    }
                }
                if( !fileProcessed ) {
                    Thread.Sleep( 50 );
                    break;
                }
            }
        }
    }

    private void button1_Click( object sender, EventArgs e ) {
        assignmentWorker.RunWorkerAsync();
    }

我对这个答案不满意，因为我不知道为什么，它确实不像你最初设计的那样有效。也许其他人可以回答......？至少这将为您提供一个工作版本。

编辑：你的原始版本不起作用，因为BackgroundWorkerFilesRunWorkerCompleted运行在与button1_Click（UI线程）相同的线程上。由于您没有释放UI线程，因此该线程永远不会被标记为完整。

Answer 2

完成Ethan Brown的回答后，问题实际上来自于你在UI线程中运行一个永远繁忙的循环。

如果filesToProcess低于最大线程数，则循环将每个文件分配给一个线程并退出。没有问题。

但是如果你有比线程更多的文件，那么看看在所有线程都在运行时尝试处理文件时会发生什么：

• 你检查所有线程是否都忙，是的。
• 你等待线程睡眠。

问题是当后台工作程序完成时，它会将消息发布到UI线程消息队列中。而你的UI线程实际上正在忙着检查你的线程并等待。

要解决这个问题：

• 你把循环放在另一个线程中（如Ethan Brown的解决方案）
• 要么在Thread.Sleep（）之前或之后添加Application.DoEvents()，以强制UI线程处理消息。这不是一个很好的做法，但在这里很好地说明了这个问题。