11

我正在尝试设置多个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);
        }
    }
}
4

2 回答 2

11

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

    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();
    }

我对这个答案不满意，因为我不知道为什么，确切地说，它不像你最初设计的那样工作。也许其他人可以回答...？至少这会给你一个工作版本。

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

于 2012-05-22T01:11:06.353 回答
1

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

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

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

  • 你检查是否所有线程都忙，是的。
  • 您通过执行线程睡眠来等待。

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

要解决这个问题：

  • 要么将循环放在另一个线程中（作为 Ethan Brown 的解决方案）
  • 您可以在 Thread.Sleep() 之前或之后添加Application.DoEvents()，以强制您的 UI 线程处理消息。这不是很好的做法，但很好地说明了这里的问题。
于 2019-03-01T14:05:13.190 回答