view Implab/AsyncPool.cs @ 3:1e9583086e99

Added Impl.Fx
author cin
date Fri, 13 Sep 2013 12:54:28 +0400
parents 279591fb4df3
children
line wrap: on
line source

using System;
using System.Threading;

namespace Implab {
	/// <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;
		}
	}
}