C＃線程隊列同步

Question

問候，我試圖播放一些音頻文件，而不阻止GUI。以下是代碼示例：

if (audio) 
{ 
    if (ThreadPool.QueueUserWorkItem(new WaitCallback(CoordinateProc), fireResult)) 
    { 

    } 
    else 
    { 
     MessageBox.Show("false"); 
    } 
} 

if (audio) 
{ 
    if (ThreadPool.QueueUserWorkItem(new WaitCallback(FireProc), fireResult)) 
    { 

    } 
    else 
    { 
     MessageBox.Show("false"); 
    } 
} 

if (audio) 
{ 
    if (ThreadPool.QueueUserWorkItem(new WaitCallback(HitProc), fireResult)) 
    { 

    } 
    else 
    { 
     MessageBox.Show("false"); 
    } 
} 

情況是樣本未按順序播放。有些在另一個之前播放，我需要解決這個問題，因此樣品依次播放。

我該如何執行此操作？

謝謝。

編輯：ThreadPool.QueueUserWorkItem(new WaitCallback(FireAttackProc), fireResult);

我已經把我所有的聲音片段在FireAttackProc。這是不行的，我想要的是：等到線程停止運行，然後再開始一個新的線程，這樣樣本不會重疊。

Answer 1

爲什麼不只是創建一個「WorkItem」，並在那裏做所有事情？

Answer 2

你應該看看BackgroundWorker選項！

Answer 3

您不能保證線程池線程的執行順序。正如其他人所建議的那樣，使用單個線程按順序運行特效。將音頻過程添加到隊列中，運行單個線程，按順序將每個過程從隊列中拉出並調用它們。每當proc被添加到隊列時，使用事件等待句柄來發信號通知線程。

一個例子（這並不能完全實現Dispose模式...但你的想法）：

public class ConcurrentAudio : IDisposable 
{ 
    public ConcurrentAudio() 
    { 
     _queue = new ConcurrentQueue<WaitCallback>(); 
     _waitHandle = new AutoResetEvent(false); 
     _disposed = false; 
     _thread = new Thread(RunAudioProcs); 
     _thread.IsBackground = true; 
     _thread.Name = "run-audio"; 
     _thread.Start(null); // pass whatever "state" you need 
    } 

    public void AddAudio(WaitCallback proc) 
    { 
     _queue.Enqueue(proc); 
     _waitHandle.Set(); 
    } 

    public void Dispose() 
    { 
     _disposed = true; 
     _thread.Join(1000); // don't feel like waiting forever 
     GC.SuppressFinalize(this); 
    } 

    private void RunAudioProcs(object state) 
    { 
     while (!_disposed) 
     { 
      try 
      { 
       WaitCallback proc = null; 

       if (_queue.TryDequeue(out proc)) 
        proc(state); 
       else 
        _waitHandle.WaitOne(); 
      } 
      catch (Exception x) 
      { 
       // Do something about the error... 
       Trace.WriteLine(string.Format("Error: {0}", x.Message), "error"); 
      } 
     } 
    } 

    private ConcurrentQueue<WaitCallback> _queue; 
    private EventWaitHandle _waitHandle; 
    private bool _disposed; 
    private Thread _thread; 
}