C# 队列（Queue）解决简单并发

资料来源：网络整理时间：2023/2/14 0:41:46 共计：3618 浏览

日志例子：

private static Queue<string> m_Message = new Queue<string>();
        private static bool m_IsRunning;
public void LogResult2(string sWord)
        {
            lock (m_Message)
            {
                //将日志加入到队列中
                m_Message.Enqueue(sWord);
            }
            //判断打印日志的方法是否在跑
            if (!m_IsRunning)
            {
                m_IsRunning = true;
                System.Threading.ThreadPool.QueueUserWorkItem(delegate
                {
                    Print();
                });
            }
        }
        //打印日志
        private static void Print()
        {
            while (true)
            {
                var messge = string.Empty;
                lock (m_Message)
                {
                    //队列里的条数为0时，跳出
                    if (m_Message.Count == 0)
                    {
                        m_IsRunning = false;
                        return;
                    }
                    //取出队列里的值
                    messge = m_Message.Dequeue();
                    string filePath = AppDomain.CurrentDomain.BaseDirectory + DateTime.Now.ToString("yyyyMMdd") + ".txt";
                    FileStream fs = new FileStream(filePath, FileMode.Append);
                    StreamWriter sw = new StreamWriter(fs, System.Text.Encoding.Default);
                    sw.Write(messge);
                    sw.Close();
                    fs.Close();
                }
            }
        }

版权说明：
本网站凡注明“广州京杭原创”的皆为本站原创文章，如需转载请注明出处！
本网转载皆注明出处，遵循行业规范，如发现作品内容版权或其它问题的，请与我们联系处理！
欢迎扫描右侧微信二维码与我们联系。

·上一条：C#使用消息队列(MSMQ) | ·下一条：C# SignalR 即时通讯聊天室