|
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 => {
|
|
48
|
20 TraceContext.Fork(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(() => {
|
|
48
|
37 TraceContext.Fork(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 }
|
|
48
|
49
|
|
|
50
|
|
|
51 public static IPromiseBase InvokeNewThread(Action func) {
|
|
|
52 var p = new Promise<object>();
|
|
|
53
|
|
|
54 var caller = TraceContext.Snapshot();
|
|
|
55
|
|
|
56 var worker = new Thread(() => {
|
|
|
57 TraceContext.Fork(caller);
|
|
|
58 try {
|
|
|
59 func();
|
|
|
60 p.Resolve();
|
|
|
61 } catch (Exception e) {
|
|
|
62 p.Reject(e);
|
|
|
63 }
|
|
|
64 });
|
|
|
65 worker.IsBackground = true;
|
|
|
66 worker.Start();
|
|
|
67
|
|
|
68 return p;
|
|
|
69 }
|
|
25
|
70 }
|
|
|
71 }
|
