Added Action onStart

Author: mofrison

AsyncTask.cs

@@ -10,17 +10,20 @@ public enum Priority { Default, High, Interrupt }
         public readonly Priority priority;
         private readonly Task task;
         private CancellationTokenSource cancellationToken;
+        private readonly System.Action<AsyncTask> onStart;
         private readonly System.Action<AsyncTask> onExit;
 
-        public AsyncTask(Task task, System.Action<AsyncTask> onExit, Priority priority) 
+        public AsyncTask(Task task, System.Action<AsyncTask> onStart,  System.Action<AsyncTask> onExit, Priority priority) 
         { 
             this.task = task;
             this.priority = priority;
+            this.onStart = onStart;
             this.onExit = onExit;
         }
 
         public async System.Threading.Tasks.Task Run()
         {
+            onStart?.Invoke(this);
             cancellationToken = new CancellationTokenSource();
             await task(cancellationToken);
             cancellationToken.Dispose();

AsyncTaskQueue.cs

@@ -77,7 +77,7 @@ public void Add(AsyncTask item)
 
         public AsyncTask Add(Task task, Priority priority = Priority.Default)
         {
-            var asyncTask = new AsyncTask(task, RemoveFromCurrentTasks, priority);
+            var asyncTask = new AsyncTask(task, AddToCurrentTasks, RemoveFromCurrentTasks, priority);
             Add(asyncTask);
             return asyncTask;
         }
@@ -101,17 +101,9 @@ public AsyncTask GetNext()
 
             if (queue.Count > 0)
             {
-                if(curentTasks.Count < maxNumberOfThreads)
-                {
-                    curentTasks.Insert(0, queue[0]);
-                    queue.Remove(curentTasks[0]);
-                    return curentTasks[0];
-                }
-                else
-                {
-                    throw new Exception(
-                        string.Format("[{0}] error: the list of current tasks is full, wait until one of the current tasks is completed", this));
-                }
+                var nextTask = queue[0];
+                queue.Remove(nextTask);
+                return nextTask;
             }
             return null;
         }
@@ -151,6 +143,19 @@ public void Clear()
             }
         }
 
+        private void AddToCurrentTasks(AsyncTask task)
+        {
+            if (curentTasks.Count < maxNumberOfThreads)
+            {
+                curentTasks.Insert(0, task);
+            }
+            else
+            {
+                throw new Exception(
+                    string.Format("[{0}] error: the list of current tasks is full, wait until one of the current tasks is completed", this));
+            }
+        }
+
         private void RemoveFromCurrentTasks(AsyncTask task)
         {
             if (curentTasks.Contains(task)) { curentTasks.Remove(task); }