ManualResetEvent线程信号Demo

using System;
using System.Collections;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Security.Permissions;
using System.Text;
using System.Threading;

namespace Log测试
{
    public class LogHeper
    {
        /// <summary>
        /// 线程安全队列
        /// </summary>
        private static readonly ConcurrentQueue<string> _que = new ConcurrentQueue<string>();

        /// <summary>
        /// 线程信号事件
        /// </summary>
        private static readonly ManualResetEvent _mre = new ManualResetEvent(false);

        /// <summary>
        /// 线程安全哈希表（添加Log类型）
        /// </summary>
        private static Hashtable LogHast = new Hashtable();

        /// <summary>
        /// 线程取消信号
        /// </summary>
        private static CancellationTokenSource token = null;

        /// <summary>
        /// 写日志线程
        /// </summary>
        private static Thread th;

        /// <summary>
        /// 日志类型枚举
        /// </summary>
        private enum LogType
        {
            INFO, ERROR
        }

        /// <summary>
        /// 开始运行写日志线程
        /// </summary>
        public static void Strar()
        {
            //初始化线程信号
            token = new CancellationTokenSource();
            th = new Thread(new ThreadStart(WriteLog))
            {
                IsBackground = false
            };
            th.Start();
        }

        /// <summary>
        /// 取消线程方法
        /// </summary>
        private static void KillTheThread()
        {
            //获得信号,不然会阻塞线程,无法停止线程
            _mre.Set();
            token.Cancel();
            //  th.Abort();
        }

        /// <summary>
        /// 外部调用取消线程
        /// </summary>
        public static void Stop()
        {
            KillTheThread();
        }

        /// <summary>
        /// 外部调用写入Info信息
        /// 加入ConcurrentQueue集合
        /// ManualResetEvent设置为有信号模式
        /// </summary>
        /// <param name="data">传入的信息</param>
        public static void WriteInfoLog(string data)
        {
            if (string.IsNullOrEmpty(data)) return;

            LogHast.Add(LogType.INFO, data);
            System.Diagnostics.Debug.WriteLine(data);
            _que.Enqueue($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} 【INFO】 ： {data}
");
            _mre.Set();
        }

        /// <summary>
        /// 外部调用写入Error信息
        /// </summary>
        /// <param name="data"></param>
        public static void WriteErrorLog(string data)
        {
            if (string.IsNullOrEmpty(data)) return;

            LogHast.Add(LogType.ERROR, data);
            System.Diagnostics.Debug.WriteLine(data);
            _que.Enqueue($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} 【ERROR】 ： {data}
");
            _mre.Set();
        }

        /// <summary>
        /// 写日志方法
        /// </summary>
        private static void WriteLog()
        {
            try
            {
                string path = AppDomain.CurrentDomain.BaseDirectory + @"logs";
                if (!Directory.Exists(path)) Directory.CreateDirectory(path);
                while (!token.IsCancellationRequested)
                {
                    string fileInfoPath = Path.Combine(path, DateTime.Now.ToString("yyyy-MM-dd HH") + " 【INFO】.txt");
                    string fileErrorPath = Path.Combine(path, DateTime.Now.ToString("yyyy-MM-dd HH") + " 【ERROR】.txt");
                    _mre.WaitOne();
                    if (_que.Count > 0 && _que.TryDequeue(out string msg))
                    {
                        lock (LogHast.SyncRoot)
                        {
                            if (LogHast.ContainsKey(LogType.ERROR))
                            {
                                File.AppendAllText(fileErrorPath, msg);
                                LogHast.Remove(LogType.ERROR);
                            }
                            else
                            {
                                File.AppendAllText(fileInfoPath, msg);
                                LogHast.Remove(LogType.INFO);
                            }
                        }
                    }
                    _mre.Reset();
                    Thread.Sleep(1);
                }
                System.Diagnostics.Debug.WriteLine("退出");
            }
            catch (ThreadAbortException ex)
            {
                throw ex;
            }
            finally
            {
                _mre.Dispose();
            }
        }
    }
}