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; 
}