##// END OF EJS Templates
implab » ImplabNet
RSS
Added ResetState to RunnableComponent to reset in case of failure...
Added ResetState to RunnableComponent to reset in case of failure Added StateChanged event to IRunnable Renamed Promise.SUCCESS -> Promise.Success Added Promise.FromException Renamed Bundle -> PromiseAll in PromiseExtensions
cin - - Load All Authors

File last commit:

r145:706fccb85524 v2
r205:8200ab154c8a v2
Show More
AsyncPool.cs
155 lines | 4.8 KiB | text/x-csharp | CSharpLexer
/ Implab / Parallels / AsyncPool.cs
History | Annotation | Raw |Copy content |Copy permalink
using Implab.Diagnostics;
using System;
using System.Threading;
using System.Linq;
namespace Implab.Parallels {
/// <summary>
/// Класс для распаралеливания задач.
/// </summary>
/// <remarks>
/// Используя данный класс и лямда выражения можно распараллелить
/// вычисления, для этого используется концепция обещаний.
/// </remarks>
public static class AsyncPool {
public static IPromise<T> Invoke<T>(Func<T> func) {
var p = new Promise<T>();
var caller = TraceContext.Instance.CurrentOperation;
ThreadPool.QueueUserWorkItem(param => {
TraceContext.Instance.EnterLogicalOperation(caller,false);
try {
p.Resolve(func());
} catch(Exception e) {
p.Reject(e);
} finally {
TraceContext.Instance.Leave();
}
});
return p;
}
public static IPromise<T> Invoke<T>(Func<ICancellationToken, T> func) {
var p = new Promise<T>();
var caller = TraceContext.Instance.CurrentOperation;
ThreadPool.QueueUserWorkItem(param => {
TraceContext.Instance.EnterLogicalOperation(caller,false);
try {
p.Resolve(func(p));
} catch(Exception e) {
p.Reject(e);
} finally {
TraceContext.Instance.Leave();
}
});
return p;
}
public static IPromise<T> RunThread<T>(Func<T> func) {
var p = new Promise<T>();
var caller = TraceContext.Instance.CurrentOperation;
var worker = new Thread(() => {
TraceContext.Instance.EnterLogicalOperation(caller,false);
try {
p.Resolve(func());
} catch (Exception e) {
p.Reject(e);
} finally {
TraceContext.Instance.Leave();
}
});
worker.IsBackground = true;
worker.Start();
return p;
}
public static IPromise<T> RunThread<T>(Func<ICancellationToken, T> func) {
var p = new Promise<T>();
var caller = TraceContext.Instance.CurrentOperation;
var worker = new Thread(() => {
TraceContext.Instance.EnterLogicalOperation(caller,false);
try {
p.Resolve(func(p));
} catch (Exception e) {
p.Reject(e);
} finally {
TraceContext.Instance.Leave();
}
});
worker.IsBackground = true;
worker.Start();
return p;
}
public static IPromise RunThread(Action func) {
var p = new Promise();
var caller = TraceContext.Instance.CurrentOperation;
var worker = new Thread(() => {
TraceContext.Instance.EnterLogicalOperation(caller,false);
try {
func();
p.Resolve();
} catch (Exception e) {
p.Reject(e);
} finally {
TraceContext.Instance.Leave();
}
});
worker.IsBackground = true;
worker.Start();
return p;
}
public static IPromise RunThread(Action<ICancellationToken> func) {
var p = new Promise();
var caller = TraceContext.Instance.CurrentOperation;
var worker = new Thread(() => {
TraceContext.Instance.EnterLogicalOperation(caller,false);
try {
func(p);
p.Resolve();
} catch (Exception e) {
p.Reject(e);
} finally {
TraceContext.Instance.Leave();
}
});
worker.IsBackground = true;
worker.Start();
return p;
}
public static IPromise[] RunThread(params Action[] func) {
return func.Select(f => RunThread(f)).ToArray();
}
public static IPromise[] RunThread(params Action<ICancellationToken>[] func) {
return func.Select(f => RunThread(f)).ToArray();
}
public static IPromise<T>[] RunThread<T>(params Func<T>[] func) {
return func.Select(f => RunThread(f)).ToArray();
}
public static IPromise<T>[] RunThread<T>(params Func<ICancellationToken, T>[] func) {
return func.Select(f => RunThread(f)).ToArray();
}
}
}