AsyncPool.cs
77 lines
| 2.3 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 { | ||||
|
cin
|
r45 | public static IPromise<T> Invoke<T>(Func<T> func) { | ||
|
cin
|
r25 | var p = new Promise<T>(); | ||
|
cin
|
r92 | var caller = TraceContext.Instance.CurrentOperation; | ||
|
cin
|
r25 | |||
| ThreadPool.QueueUserWorkItem(param => { | ||||
|
cin
|
r92 | TraceContext.Instance.EnterLogicalOperation(caller,false); | ||
|
cin
|
r25 | try { | ||
|
cin
|
r14 | p.Resolve(func()); | ||
|
cin
|
r25 | } catch(Exception e) { | ||
| p.Reject(e); | ||||
|
cin
|
r92 | } finally { | ||
| TraceContext.Instance.Leave(); | ||||
| } | ||||
|
cin
|
r25 | }); | ||
| return p; | ||||
|
cin
|
r14 | } | ||
|
cin
|
r45 | public static IPromise<T> InvokeNewThread<T>(Func<T> func) { | ||
|
cin
|
r14 | var p = new Promise<T>(); | ||
|
cin
|
r92 | var caller = TraceContext.Instance.CurrentOperation; | ||
|
cin
|
r35 | |||
|
cin
|
r14 | var worker = new Thread(() => { | ||
|
cin
|
r92 | TraceContext.Instance.EnterLogicalOperation(caller,false); | ||
|
cin
|
r14 | try { | ||
| p.Resolve(func()); | ||||
| } catch (Exception e) { | ||||
| p.Reject(e); | ||||
|
cin
|
r92 | } finally { | ||
| TraceContext.Instance.Leave(); | ||||
|
cin
|
r14 | } | ||
| }); | ||||
| worker.IsBackground = true; | ||||
| worker.Start(); | ||||
| return p; | ||||
|
cin
|
r25 | } | ||
|
cin
|
r48 | |||
|
cin
|
r66 | public static IPromise InvokeNewThread(Action func) { | ||
|
cin
|
r48 | var p = new Promise<object>(); | ||
|
cin
|
r92 | var caller = TraceContext.Instance.CurrentOperation; | ||
|
cin
|
r48 | |||
| var worker = new Thread(() => { | ||||
|
cin
|
r92 | TraceContext.Instance.EnterLogicalOperation(caller,false); | ||
|
cin
|
r48 | try { | ||
| func(); | ||||
| p.Resolve(); | ||||
| } catch (Exception e) { | ||||
| p.Reject(e); | ||||
|
cin
|
r92 | } finally { | ||
| TraceContext.Instance.Leave(); | ||||
|
cin
|
r48 | } | ||
| }); | ||||
| worker.IsBackground = true; | ||||
| worker.Start(); | ||||
| return p; | ||||
| } | ||||
|
cin
|
r25 | } | ||
| } | ||||