Merge pull request #33 from dotnet-campus/t/walterlv/channel

优化日志写入性能，公开后台写入日志相关的方法

Author: lindexi

src/dotnetCampus.Logger/Writers/Helpers/ICoreLogWriter.cs

@@ -1,13 +1,18 @@
 using System;
-using System.Collections.Concurrent;
 using System.Threading.Tasks;
 
+#if NET6_0_OR_GREATER
+using System.Threading.Channels;
+#else
+using System.Collections.Concurrent;
+#endif
+
 namespace dotnetCampus.Logging.Writers.Helpers;
 
 /// <summary>
 /// 提供各种不同线程安全方式的最终日志写入功能。
 /// </summary>
-internal interface ICoreLogWriter
+public interface ICoreLogWriter
 {
     /// <summary>
     /// 写入日志。
@@ -78,32 +83,89 @@ public void Do(Action action)
 internal sealed class ProducerConsumerLogWriter : ICoreLogWriter
 {
     private readonly Action<string> _logger;
+#if NET6_0_OR_GREATER
+    private readonly Channel<object> _queue = Channel.CreateUnbounded<object>(new UnboundedChannelOptions
+    {
+        SingleReader = true,
+        SingleWriter = false,
+        AllowSynchronousContinuations = false,
+    });
+#else
     private readonly BlockingCollection<object> _queue = new();
+#endif
 
     /// <summary>
     /// 创建 <see cref="ProducerConsumerLogWriter"/> 的新实例，并启动消费线程。
     /// </summary>
     public ProducerConsumerLogWriter(Action<string> logger)
     {
         _logger = logger;
+#if NET6_0_OR_GREATER
+        _ = Task.Run(Consume);
+#else
         new Task(Consume, TaskCreationOptions.LongRunning).Start();
+#endif
     }
 
     /// <inheritdoc />
     public void Write(string? message)
     {
         if (message is not null)
         {
+#if NET6_0_OR_GREATER
+            _queue.Writer.TryWrite(message);
+#else
             _queue.Add(message);
+#endif
         }
     }
 
     /// <inheritdoc />
     public void Do(Action action)
     {
+#if NET6_0_OR_GREATER
+        _queue.Writer.TryWrite(action);
+#else
         _queue.Add(action);
+#endif
     }
 
+#if NET6_0_OR_GREATER
+    /// <summary>
+    /// 消费队列中的元素。
+    /// </summary>
+    private async Task Consume()
+    {
+        while (true)
+        {
+            var success = await _queue.Reader.WaitToReadAsync();
+            if (!success)
+            {
+                break;
+            }
+
+            while (_queue.Reader.TryRead(out var item))
+            {
+                try
+                {
+                    switch (item)
+                    {
+                        case string message:
+                            _logger(message);
+                            break;
+                        case Action action:
+                            action();
+                            break;
+                    }
+                }
+                catch (Exception)
+                {
+                    // 本次日志发生了异常，已经无法继续写入日志，只能抛弃异常。
+                }
+            }
+        }
+    }
+#else
     /// <summary>
     /// 消费队列中的元素。
     /// </summary>
@@ -122,4 +184,5 @@ private void Consume()
             }
         }
     }
+#endif
 }

src/dotnetCampus.Logger/Writers/LogWritingThreadMode.cs

@@ -30,7 +30,7 @@ public enum LogWritingThreadMode
 /// <summary>
 /// 包含 <see cref="LogWritingThreadMode"/> 的扩展方法。
 /// </summary>
-internal static class LogWritingThreadModeExtensions
+public static class LogWritingThreadModeExtensions
 {
     /// <summary>
     /// 根据 <see cref="LogWritingThreadMode"/> 创建对应的 <see cref="ICoreLogWriter"/> 实例。