csharp-queue

发表于 更新于 分类于 阅读次数： 本文字数： 330 阅读时长 ≈ 1 分钟 
// 多线程使用 ConcurrentQueue
ConcurrentQueue<byte[]> que_sp = new ConcurrentQueue<byte[]>();

public void Task_SP()
{
    byte[] datas = null;
    while (FLAG_EXIT != (m_flag & FLAG_EXIT))
    {
        if (que_sp.TryDequeue(out datas))
        {
            siemensHelper.Write_bytes("DB.20.2075", ref datas, 47);
        }else
        {
            Thread.Sleep(1);
        }
    }
}