Merge pull request #31 from dotnet-campus/t/lindexi/nullable-asyncqueue

加上可空

Author: kkwpsv

AsyncWorkerCollection/AsyncAutoResetEvent.cs

@@ -1,4 +1,5 @@
-using System;
+#nullable enable
+using System;
 using System.Collections.Generic;
 using System.Threading.Tasks;
 
@@ -24,6 +25,9 @@ public AsyncAutoResetEvent(bool initialState)
             _isSignaled = initialState;
         }
 
+        /// <summary>
+        /// 析构方法
+        /// </summary>
         ~AsyncAutoResetEvent()
         {
             Dispose();
@@ -68,7 +72,7 @@ public Task<bool> WaitOneAsync()
         /// </summary>
         public void Set()
         {
-            TaskCompletionSource<bool> releaseSource = null;
+            TaskCompletionSource<bool>? releaseSource = null;
             bool result;
             lock (_locker)
             {

AsyncWorkerCollection/AsyncQueue.cs

@@ -1,4 +1,5 @@
-using System;
+#nullable enable
+using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Threading;
@@ -96,7 +97,7 @@ public async Task<T> DequeueAsync(CancellationToken cancellationToken = default)
                 }
             }
 
-            return default;
+            return default!;
         }
 
         /// <summary>
@@ -175,7 +176,7 @@ private void ThrowIfDisposing()
             }
         }
 
-        private event EventHandler CurrentFinished;
+        private event EventHandler? CurrentFinished;
 
         private bool _isDisposing;
         private bool _isDisposed;