AsyncPool.cs
50 lines
| 1.4 KiB
| text/x-csharp
|
CSharpLexer
cin
|
r35 | using Implab.Diagnostics; | ||
|
cin
|
r25 | 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>(); | ||||
|
cin
|
r40 | var caller = TraceContext.Snapshot(); | ||
|
cin
|
r25 | |||
| ThreadPool.QueueUserWorkItem(param => { | ||||
|
cin
|
r40 | TraceContext.Transfer(caller); | ||
|
cin
|
r25 | try { | ||
|
cin
|
r14 | p.Resolve(func()); | ||
|
cin
|
r25 | } catch(Exception e) { | ||
| p.Reject(e); | ||||
| } | ||||
| }); | ||||
| return p; | ||||
|
cin
|
r14 | } | ||
| public static Promise<T> InvokeNewThread<T>(Func<T> func) { | ||||
| var p = new Promise<T>(); | ||||
|
cin
|
r40 | var caller = TraceContext.Snapshot(); | ||
|
cin
|
r35 | |||
|
cin
|
r14 | var worker = new Thread(() => { | ||
|
cin
|
r40 | TraceContext.Transfer(caller); | ||
|
cin
|
r14 | try { | ||
| p.Resolve(func()); | ||||
| } catch (Exception e) { | ||||
| p.Reject(e); | ||||
| } | ||||
| }); | ||||
| worker.IsBackground = true; | ||||
| worker.Start(); | ||||
| return p; | ||||
|
cin
|
r25 | } | ||
| } | ||||
| } | ||||