pub/ImplabNet: Implab/Parallels/AsyncPool.cs comparison

Слияние с promises

comparison

equal deleted inserted replaced

-:dfa21d507bc5
+:0c924dff5498
+using System;
+using System.Threading;
+namespace Implab.Parallels {
+	/// <summary>
+	/// Класс для распаралеливания задач.
+	/// </summary>
+	/// <remarks>
+	/// Используя данный класс и лямда выражения можно распараллелить
+	/// вычисления, для этого используется концепция обещаний.
+	/// </remarks>
+	public static class AsyncPool {
+		public static Promise<T> Invoke<T>(Func<T> func) {
+			var p = new Promise<T>();
+			ThreadPool.QueueUserWorkItem(param => {
+				try {
+					p.Resolve(func());
+				} catch(Exception e) {
+					p.Reject(e);
+				}
+			});
+			return p;
+		}
+public static Promise<T> InvokeNewThread<T>(Func<T> func) {
+var p = new Promise<T>();
+var worker = new Thread(() => {
+try {
+p.Resolve(func());
+} catch (Exception e) {
+p.Reject(e);
+}
+});
+worker.IsBackground = true;
+worker.Start();
+return p;
+}
+	}
+}

Mercurial > pub > ImplabNet