多个线程订阅同一个事件信号唤醒

Question

我有一个队列包装类，它将项目存储到一个列表中，主程序中的多个线程正在使用这些项目，直到列表为空。此时，线程必须等待，直到缓冲区将更多项目排入列表。

每当一个项目入队时，我都会触发一个事件，我需要通知线程他们有新的项目可供使用。

 public event EventHandler ItemEnqueued;

    public void Enqueue(string item)
    {
        _itemsList.Add(item);            
        OnItemEnqueued();
    }
    

    void OnItemEnqueued()
    {
        ItemEnqueued?.Invoke(this, EventArgs.Empty);
    }

如何通知主程序的线程一个项目已入队？

非常感谢！

编辑澄清

    public class Queue 
{
    private readonly List<string> _itemsList = new List<string>();

    public void Enqueue(String val)
    {
        _itemsList.Add(val);            
        OnItemEnqueued();
    }
    

    void OnItemEnqueued()
    {
        //here I have to tell the threads that a new item has been added
    }

    public string Dequeue()
    {
            //FIFO queue
            if (_itemsList.Any())
            {
                var first = _itemsList.First();
                _itemsList.RemoveAt(0);

                return first;
            }
            
            return default(string);
       
    }

    public int Count()
    {
        return _itemsList.Count;
    }
}

}

我必须创建两个线程并让它们为排队的项目“战斗”：

    class Program
{
    readonly object _syncLock = new object();
    Queue _q = new Queue();
    static void Main(string[] args)
    {
        Program p = new Program();
        p.InitThreads();
        
    }

    public void InitThreads()
    {
        lock (_syncLock) //exclusively add items 
        {
            for (var i = 0; i <= 99; i++)
            {
                _q.Enqueue(i.ToString());
            }
        }

        Thread t1 = new Thread(() => {
            while(_q.Count() > 0)
                Console.WriteLine("T1 dequeued " + Consume());

        });

        Thread t2 = new Thread(() =>
        {
            while (_q.Count() > 0)
                Console.WriteLine("T2 dequeued " + Consume());              
        });
        

        t1.Start();
        t2.Start();

        //at some moment I have to tell the threads to wait until a new item has been enqueued
    }

    public string Consume()
    {
        lock (_syncLock) //safely get one item
        {
            return _q.Dequeue(); 
        }
    }

}

Answer 1

不确定这是否是您要查找的内容，但这里有一个可兼容的代码示例，演示了如何使用 AutoResetEvent 一次仅向一个线程发出信号：

using System;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    static class Program
    {
        public static void Main()
        {
            var signal = new AutoResetEvent(initialState:false);

            for (int i = 0; i < 4; ++i)
                Task.Run(() => worker(signal));

            while (true)
            {
                Console.WriteLine("Press <ENTER> to wake a thread.");
                Console.ReadLine();
                signal.Set();
            }
        }

        static void worker(AutoResetEvent signal)
        {
            int threadId = Thread.CurrentThread.ManagedThreadId;

            while (true)
            {
                Console.WriteLine($"Thread {threadId} is waiting for a signal.");
                signal.WaitOne();
                Console.WriteLine($"Thread {threadId} received a signal");
            }
        }
    }
}

要注意的关键是你创建了一个AutoResetEvent 并将它传递给所有线程，然后等待它。然后，当“主”线程希望其中一个线程响应时，它会发出事件信号。

我不会为这种事情使用ManualResetEvent，因为这样所有线程都会同时发出信号，看起来你想避免这种情况。