Mercurial > pub > ImplabNet
view Implab/Parallels/AsyncPool.cs @ 11:6ec82bf68c8e promises
refactoring
author | cin |
---|---|
date | Tue, 05 Nov 2013 01:09:58 +0400 |
parents | |
children | e943453e5039 |
line wrap: on
line source
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; } } }