修改为异步方法

#5

Author: lindexi

AsyncWorkerCollection/AsyncTaskQueue_/AsyncTaskQueue.cs

@@ -1,6 +1,6 @@
 using System;
 using System.Collections.Concurrent;
-using System.Threading;
+using System.Diagnostics;
 using System.Threading.Tasks;
 
 namespace dotnetCampus.Threading
@@ -15,9 +15,8 @@ public class AsyncTaskQueue : IDisposable
         /// </summary>
         public AsyncTaskQueue()
         {
-            _autoResetEvent = new AutoResetEvent(false);
-            _thread = new Thread(InternalRunning) { IsBackground = true };
-            _thread.Start();
+            _autoResetEvent = new AsyncAutoResetEvent(false);
+            InternalRunning();
         }
 
         #region 执行
@@ -102,14 +101,14 @@ private void AddPendingTaskToQueue(AwaitableTask task)
 
         #region 内部运行
 
-        private void InternalRunning()
+        private async void InternalRunning()
         {
             while (!_isDisposed)
             {
                 if (_queue.Count == 0)
                 {
                     //等待后续任务
-                    _autoResetEvent.WaitOne();
+                    await _autoResetEvent.WaitOneAsync();
                 }
 
                 while (TryGetNextTask(out var task))
@@ -151,6 +150,7 @@ private bool TryGetNextTask(out AwaitableTask task)
                     return true;
                 }
 
+                Debug.Assert(task != null);
                 //并发操作，设置任务不可执行
                 task.SetNotExecutable();
             }
@@ -182,10 +182,10 @@ private void Dispose(bool disposing)
             if (_isDisposed) return;
             if (disposing)
             {
-                _autoResetEvent.Dispose();
+                //_autoResetEvent.Dispose();
             }
 
-            _thread = null;
+            _queue.Clear();
             _autoResetEvent = null;
             _isDisposed = true;
         }
@@ -206,8 +206,7 @@ private void Dispose(bool disposing)
 
         private bool _isDisposed;
         private readonly ConcurrentQueue<AwaitableTask> _queue = new ConcurrentQueue<AwaitableTask>();
-        private Thread _thread;
-        private AutoResetEvent _autoResetEvent;
+        private AsyncAutoResetEvent _autoResetEvent;
 
         #endregion
     }