当完成时，BackgroundWorkers队列引发事件

问题描述

我需要执行 n BackgroundWorkers，当他们完成时，我想引发一个事件，并根据他们的所有工作来做些事情。我的用例是创建队列，填充队列，然后仅运行一次。为此，我制作了一个ParallelQueue类。经过最初的测试，它似乎可以正常工作，但是我担心条件_max == _iteration并不是最好的条件，那就是评估队列中的所有工作是否已经完成。还是我对Queue的使用不是线程安全的，我应该使用什么来完成此任务？（ConcurrentQueue？）如果这个问题太笼统，我将其删除，谢谢。

public class ParallelQueue
{
    private Queue<BackgroundWorker> _queue;
    private readonly object _key = new object();
    private int _max = 0;
    private int _iteration = 0;
    private bool _ran = false;

    public ParallelQueue()
    {
        _queue = new Queue<BackgroundWorker>();
    }

    public delegate void BackgroundQueueCompleted(object sender,RunWorkerCompletedEventArgs e);
    public event BackgroundQueueCompleted QueueCompleted;

    public void Add(BackgroundWorker worker)
    {
        worker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(WorkerCompleted);
        _queue.Enqueue(worker);
    }

    public void Run()
    {
        lock (_key)
        {
            if(!_queue.Any()) throw new ArgumentOutOfRangeException("ParallelQueue cannot be empty");
            if (_ran) throw new InvalidOperationException("ParallelQueue can only be run once");
            _ran = true;

            _max = _queue.Count();
            Parallel.For(0,_queue.Count,(i,state) =>
            {
                BackgroundWorker worker = _queue.Dequeue();
                worker.RunWorkerAsync();
            });
        }
    }

    private void WorkerCompleted(object sender,RunWorkerCompletedEventArgs e)
    {
        Interlocked.Increment(ref _iteration);
        if (_max == _iteration)
        {
            QueueCompleted?.Invoke(this,e);
        }
    }
}

使用ParallelQueue的示例

public class Program
{
    static void Main(string[] args)
    {
        var queue = new ParallelQueue();
        queue.QueueCompleted += MyQueueCompletedHandler;

        for (int i = 0; i < 10; i++)
        {
            BackgroundWorker bw = new BackgroundWorker();
            bw.DoWork += new DoWorkEventHandler((sender,e) =>
            {
                Thread.Sleep(500);
            });
            queue.Add(bw);
        }

        queue.Run();
        Console.ReadLine();

    }

    private static void MyQueueCompletedHandler(object sender,RunWorkerCompletedEventArgs e)
    {
        Console.WriteLine("queue is complete");
    }
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

asynchronous backgroundworker c#c#