AsyncPool.cs
28 lines
| 701 B
| text/x-csharp
|
CSharpLexer
cin
|
r11 | 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; | ||||
| } | ||||
| } | ||||
| } | ||||