параллельные операции с аудио потоком C#

Question

я запись звука в C# (WPF) и когда данные из звуковой карты доступна она называет это событие:

void myWaveIn_DataAvailable(object sender, WaveInEventArgs e) 
    { 
     for (int index = 0; index < e.BytesRecorded; index += 2)//Here I convert in a loop the stream into floating number samples 
     { 

      short sample = (short)((e.Buffer[index + 1] << 8) | 
            e.Buffer[index + 0]); 
      samples32Queue.Enqueue(sample/32768f); 
     } 
     //***Do some Processing with data inside Queue 
    } 

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

Queue<float> samples32Queue = new Queue<float>(); 

Как вы можете видеть внутри события после for loop я хочу сделать некоторую обработку очереди. Я волнуюсь, что при обработке данных новые звуковые карты будут получены из звуковой карты, и моя обработка будет потеряна.

1. Каков правильный подход к этому?
2. Является ли обработка, которую я вызываю из события, является статическим методом/нестационарным?

Answer 1

Учитывая тот факт, что вы можете буферизовать образцы и обрабатывать их позже, рассмотрите возможность использования BlockingCollection. BlockingCollection - отличное решение для шаблона производителя-потребителя, которое, насколько я понимаю, является вашим делом. С одной стороны у вас есть метод myWaveIn_DataAvailable() как производитель, добавляющий образцы в коллекцию, а с другой стороны у вас есть другой потребляющий поток (он не должен быть другим потоком), собирая образцы и обрабатывая их. Существуют различные способы реализации потребителя, и они хорошо документированы в MSDN.

EDIT: Смотрите следующий пример, я не проверял, но это должно дать вам начальную точку:

class ProducerConsumerExample 
{ 
    BlockingCollection<float> samples32Collection; 
    Thread consumer; 
    public ProducerConsumerExample() 
    { 
     samples32Collection = new BlockingCollection<float>(); 
     consumer = new Thread(() => LaunchConsumer()); 
     consumer.Start(); //you don't have to luanch the consumer here... 
    } 
    void Terminate() //Call this to terminate the consumer 
    { 
     consumer.Abort(); 
    } 
    void myWaveIn_DataAvailable(object sender, WaveInEventArgs e) 
    { 
     for (int index = 0; index < e.BytesRecorded; index += 2)//Here I convert in a loop the stream into floating number samples 
     { 

      short sample = (short)((e.Buffer[index + 1] << 8) | 
            e.Buffer[index + 0]); 
      samples32Collection.Add(sample/32768f); 
     } 
    } 

    void LaunchConsumer() 
    { 
     while (true /* insert your abort condition here*/) 
     { 
      try 
      { 
       var sample = samples32Collection.Take(); //this thread will wait here until the producer add new item(s) to the collection 
       Process(sample); //in the meanwhile, more samples could be added to the collection 
            //but they will not be processed until this thread is done with Process(sample) 
      } 
      catch (InvalidOperationException) { } 
     } 
    } 
}