|
35
|
1 using Implab.Diagnostics;
|
|
25
|
2 using System;
|
|
|
3 using System.Threading;
|
|
|
4
|
|
|
5 namespace Implab.Parallels {
|
|
|
6 /// <summary>
|
|
|
7 /// Класс для распаралеливания задач.
|
|
|
8 /// </summary>
|
|
|
9 /// <remarks>
|
|
|
10 /// Используя данный класс и лямда выражения можно распараллелить
|
|
|
11 /// вычисления, для этого используется концепция обещаний.
|
|
|
12 /// </remarks>
|
|
|
13 public static class AsyncPool {
|
|
|
14
|
|
45
|
15 public static IPromise<T> Invoke<T>(Func<T> func) {
|
|
25
|
16 var p = new Promise<T>();
|
|
40
|
17 var caller = TraceContext.Snapshot();
|
|
25
|
18
|
|
|
19 ThreadPool.QueueUserWorkItem(param => {
|
|
40
|
20 TraceContext.Transfer(caller);
|
|
25
|
21 try {
|
|
14
|
22 p.Resolve(func());
|
|
25
|
23 } catch(Exception e) {
|
|
|
24 p.Reject(e);
|
|
|
25 }
|
|
|
26 });
|
|
|
27
|
|
|
28 return p;
|
|
14
|
29 }
|
|
|
30
|
|
45
|
31 public static IPromise<T> InvokeNewThread<T>(Func<T> func) {
|
|
14
|
32 var p = new Promise<T>();
|
|
|
33
|
|
40
|
34 var caller = TraceContext.Snapshot();
|
|
35
|
35
|
|
14
|
36 var worker = new Thread(() => {
|
|
40
|
37 TraceContext.Transfer(caller);
|
|
14
|
38 try {
|
|
|
39 p.Resolve(func());
|
|
|
40 } catch (Exception e) {
|
|
|
41 p.Reject(e);
|
|
|
42 }
|
|
|
43 });
|
|
|
44 worker.IsBackground = true;
|
|
|
45 worker.Start();
|
|
|
46
|
|
|
47 return p;
|
|
25
|
48 }
|
|
|
49 }
|
|
|
50 }
|
