Mercurial > pub > ImplabNet
view Implab/AsyncPool.cs @ 0:279591fb4df3
initial commit
promises async model
author | user@factory.site.local |
---|---|
date | Fri, 23 Aug 2013 04:38:46 +0400 |
parents | |
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; } } }