Использование очереди в C#?

Question

Итак, я работаю над консольным приложением, которое извлекает из API каждые 3 секунды. API возвращает список «Сообщения», который мне нужно добавить в очередь, и что-то в фоновом режиме постоянно проверяет наличие новых элементов в очереди, перебирает элементы, делает что-то с элементами.

Вот то, что я до сих пор: Основная программа Метод

static void Main(string[] args) 
{ 
    ConsoleKeyInfo answer = Console.ReadKey(true); 
    if (answer.Key == ConsoleKey.Y) 
    { 
     while (true) 
     { 
      foreach (MessageObject message in messageQueue) 
      { 
       SendCommand(message.Message); 

       // Debug 
       Console.WriteLine(message.Message); 
       messageQueue.Dequeue(); 
      } 
     } 
    } 
    else 
    { 
     Environment.Exit(0); 
    } 
} 

CheckChat Метод

static private async void CheckChat() 
{ 
    Chat chat = await ChatAPI.GetChat(428); 

    foreach (MessageObject chatMessage in chat.Messages) 
    { 
     messageQueue.Enqueue(chatMessage); 
    } 
} 

Однако, я получаю следующее сообщение об ошибке:

An unhandled exception of type 'System.InvalidOperationException' occurred in System.dll

Additional information: Collection was modified after the enumerator was instantiated.

Я понимаю, что я добавляю элементы в список во время цикла в очереди, но как я буду постоянно проверять элементы в очереди в качестве им добавления объектов?

Answer 1

Вам нужно создать копию очереди, если вы хотите, чтобы перечислить его в то время как она модифицируется, например, вы можете:

foreach (MessageObject message in messageQueue.ToList()) 

Обратите внимание, что во все вероятности вашей очередь также должна быть ConcurrentQueue, поскольку вы «Выполнение операций по потокам.

Answer 2

Вы можете использовать (например) петлю while вместо foreach:

while (messageQueue.Count != 0) 
{ 
    MessageObject message = messageQueue.Dequeue(); 
    Console.WriteLine(message.Message); 
} 

В этом случае нет никаких проблем с изменением очереди.