Simplified running parallel tasks on the taskpool

kenkendk · Jun 4, 2018 · cb096fd · cb096fd
1 parent 5bf0afa
commit cb096fd
Showing 1 changed file with 28 additions and 1 deletion.
diff --git a/src/CoCoL/TaskPool.cs b/src/CoCoL/TaskPool.cs
@@ -127,6 +127,33 @@ public static async Task RunParallelAsync<T>(IEnumerable<T> tasks, Func<T, Task>
             }
         }
 
+        /// <summary>
+        /// Runs a repeated parallel operation with a maximum of 10 concurrent handlers 
+        /// </summary>
+        /// <returns>An awaitable task.</returns>
+        /// <param name="source">The channel where requests are read from</param>
+        /// <param name="handler">The method to invoke for each item</param>
+        /// <param name="errorHandler">The error handler</param>
+        /// <typeparam name="T">The type of data elements to handle</typeparam>
+        public static Task RunParallelAsync<T>(IReadChannel<T> source, Func<T, Task> handler, Func<T, Exception, Task> errorHandler = null)
+        {
+            return RunParallelAsync(source, handler, default(System.Threading.CancellationToken), 10, errorHandler);
+        }
+
+        /// <summary>
+        /// Runs a repeated parallel operation 
+        /// </summary>
+        /// <returns>An awaitable task.</returns>
+        /// <param name="source">The channel where requests are read from</param>
+        /// <param name="handler">The method to invoke for each item</param>
+        /// <param name="maxparallel">The maximum parallelism to use.</param>
+        /// <param name="errorHandler">The error handler</param>
+        /// <typeparam name="T">The type of data elements to handle</typeparam>
+        public static Task RunParallelAsync<T>(IReadChannel<T> source, Func<T, Task> handler, int maxparallel, Func<T, Exception, Task> errorHandler = null)
+        {
+            return RunParallelAsync(source, handler, default(System.Threading.CancellationToken), maxparallel, errorHandler);
+        }
+
         /// <summary>
         /// Runs a repeated parallel operation 
         /// </summary>
@@ -137,7 +164,7 @@ public static async Task RunParallelAsync<T>(IEnumerable<T> tasks, Func<T, Task>
         /// <param name="maxparallel">The maximum parallelism to use.</param>
         /// <param name="errorHandler">The error handler</param>
         /// <typeparam name="T">The type of data elements to handle</typeparam>
-        public static Task RunParallelAsync<T>(IReadChannel<T> source, Func<T, Task> handler, System.Threading.CancellationToken token = default(System.Threading.CancellationToken), int maxparallel = 10, Func<T, Exception, Task> errorHandler = null)
+        public static Task RunParallelAsync<T>(IReadChannel<T> source, Func<T, Task> handler, System.Threading.CancellationToken token, int maxparallel = 10, Func<T, Exception, Task> errorHandler = null)
         {
             if (source == null)
                 throw new ArgumentNullException(nameof(source));