# HG changeset patch # User cin # Date 2014-02-05 21:08:59 # Node ID 9bf5b23650c9d25c3bb235cb6f2e91cd35c74da4 # Parent ee04e1fa78da52ee25bf6dbb4786c9a2403163ae refactoring diff --git a/Implab/IPromise.cs b/Implab/IPromise.cs --- a/Implab/IPromise.cs +++ b/Implab/IPromise.cs @@ -5,15 +5,11 @@ using System.Text; namespace Implab { - public interface IPromise: ICancellable + public interface IPromise: IPromiseBase { - /// - /// Check whereather the promise has no more than one dependent promise. - /// - bool IsExclusive - { - get; - } + + + } diff --git a/Implab/IPromiseBase.cs b/Implab/IPromiseBase.cs new file mode 100644 --- /dev/null +++ b/Implab/IPromiseBase.cs @@ -0,0 +1,19 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; + +namespace Implab { + public interface IPromiseBase: ICancellable { + /// + /// Check whereather the promise has no more than one dependent promise. + /// + bool IsExclusive { + get; + } + + bool IsResolved { get; } + + bool IsCancelled { get; } + } +} diff --git a/Implab/ITaskController.cs b/Implab/ITaskController.cs --- a/Implab/ITaskController.cs +++ b/Implab/ITaskController.cs @@ -4,9 +4,11 @@ using System.Linq; using System.Text; namespace Implab { - public interface ITaskController: IProgressHandler { - bool Cancelled { + public interface ITaskController: IProgressHandler, ICancellable { + bool IsCancelled { get; } + + event EventHandler Cancelled; } } diff --git a/Implab/Implab.csproj b/Implab/Implab.csproj --- a/Implab/Implab.csproj +++ b/Implab/Implab.csproj @@ -36,6 +36,7 @@ + diff --git a/Implab/Parallels/ArrayTraits.cs b/Implab/Parallels/ArrayTraits.cs --- a/Implab/Parallels/ArrayTraits.cs +++ b/Implab/Parallels/ArrayTraits.cs @@ -168,45 +168,5 @@ namespace Implab.Parallels { return promise.Anyway(() => semaphore.Dispose()); } - /* - this method is pretty fast, but it may cause a stack overflow if an element transformation is made faster then the next operation is - be chained, in this case the syncronous callback invocation will occur - - public static Promise ChainedMap2(this TSrc[] source, ChainedOperation transform, int threads) { - if (source == null) - throw new ArgumentNullException("source"); - if (transform == null) - throw new ArgumentNullException("transform"); - if (threads <= 0) - throw new ArgumentOutOfRangeException("Threads number must be greater then zero"); - - var promise = new Promise(); - var res = new TDst[source.Length]; - var index = -1; // we will start with increment - var len = source.Length; - var pending = len; - - Action callback = null; - callback = (current) => { - if (current < len) { - transform(source[current]) - .Then( - x => { - res[current] = x; - if (Interlocked.Decrement(ref pending) == 0) - promise.Resolve(res); - else - callback(Interlocked.Increment(ref index)); - }, - e => promise.Reject(e) - ); - } - }; - - for (int i = 0; i < threads; i++) - callback(Interlocked.Increment(ref index)); - return promise; - } - */ } } diff --git a/Implab/Parallels/AsyncPool.cs b/Implab/Parallels/AsyncPool.cs --- a/Implab/Parallels/AsyncPool.cs +++ b/Implab/Parallels/AsyncPool.cs @@ -1,28 +1,28 @@ -using System; -using System.Threading; - -namespace Implab.Parallels { - /// - /// Класс для распаралеливания задач. - /// - /// - /// Используя данный класс и лямда выражения можно распараллелить - /// вычисления, для этого используется концепция обещаний. - /// - public static class AsyncPool { - - public static Promise Invoke(Func func) { - var p = new Promise(); - - ThreadPool.QueueUserWorkItem(param => { - try { +using System; +using System.Threading; + +namespace Implab.Parallels { + /// + /// Класс для распаралеливания задач. + /// + /// + /// Используя данный класс и лямда выражения можно распараллелить + /// вычисления, для этого используется концепция обещаний. + /// + public static class AsyncPool { + + public static Promise Invoke(Func func) { + var p = new Promise(); + + ThreadPool.QueueUserWorkItem(param => { + try { p.Resolve(func()); - } catch(Exception e) { - p.Reject(e); - } - }); - - return p; + } catch(Exception e) { + p.Reject(e); + } + }); + + return p; } public static Promise InvokeNewThread(Func func) { @@ -39,6 +39,6 @@ namespace Implab.Parallels { worker.Start(); return p; - } - } -} + } + } +} diff --git a/Implab/Promise.cs b/Implab/Promise.cs --- a/Implab/Promise.cs +++ b/Implab/Promise.cs @@ -47,7 +47,7 @@ namespace Implab { /// только инициатор обещания иначе могут возникнуть противоречия. /// /// - public class Promise : IPromise { + public class Promise : IPromise { struct HandlerDescriptor { public ResultHandler resultHandler; @@ -82,11 +82,11 @@ namespace Implab { const int UnresolvedSate = 0; const int TransitionalState = 1; - const int ResolvedState = 2; + const int SucceededState = 2; const int RejectedState = 3; const int CancelledState = 4; - readonly IPromise m_parent; + readonly IPromiseBase m_parent; readonly bool m_cancellable; int m_childrenCount = 0; @@ -100,7 +100,7 @@ namespace Implab { m_cancellable = true; } - public Promise(IPromise parent, bool cancellable) { + public Promise(IPromiseBase parent, bool cancellable) { m_cancellable = cancellable; m_parent = parent; } @@ -119,6 +119,12 @@ namespace Implab { throw new InvalidOperationException("Can't complete transition when the object isn't in the transitional state"); } + void WaitTransition() { + while (m_state == TransitionalState) { + /* noop */ + } + } + public bool IsResolved { get { return m_state > 1; @@ -139,10 +145,13 @@ namespace Implab { public void Resolve(T result) { if (BeginTransit()) { m_result = result; - CompleteTransit(ResolvedState); + CompleteTransit(SucceededState); OnStateChanged(); - } else if (m_state != CancelledState) - throw new InvalidOperationException("The promise is already resolved"); + } else { + WaitTransition(); + if (m_state != CancelledState) + throw new InvalidOperationException("The promise is already resolved"); + } } /// @@ -160,8 +169,11 @@ namespace Implab { m_error = error; CompleteTransit(RejectedState); OnStateChanged(); - } else if (m_state == ResolvedState) - throw new InvalidOperationException("The promise is already resolved"); + } else { + WaitTransition(); + if (m_state == SucceededState) + throw new InvalidOperationException("The promise is already resolved"); + } } /// @@ -197,6 +209,9 @@ namespace Implab { ErrorHandler errorHandler; if (error != null) errorHandler = x => { + // несмотря на то, что обработчик ошибки вызывается безопасно, + // т.е. возникшие в нем ошибки будут подавлены, нам нужно + // гарантировать, что ошибка будет передана дальше по цепочке обещаний try { error(x); } catch { } @@ -238,8 +253,9 @@ namespace Implab { errorHandler = x => { try { medium.Resolve(error(x)); - } catch { } - medium.Reject(x); + } catch(Exception e) { + medium.Reject(e); + } }; else errorHandler = medium.Reject; @@ -257,7 +273,7 @@ namespace Implab { var medium = new Promise(this, true); ResultHandler resultHandler; - + if (success != null) resultHandler = x => { success(x); @@ -430,6 +446,11 @@ namespace Implab { return this; } + /// + /// Adds the specified handler for all cases (success, error, cancel) + /// + /// The handler that will be called anyway + /// self public Promise Finally(Action handler) { if (handler == null) throw new ArgumentNullException("handler"); @@ -471,7 +492,7 @@ namespace Implab { throw new TimeoutException(); switch (m_state) { - case ResolvedState: + case SucceededState: return m_result; case CancelledState: throw new OperationCanceledException(); @@ -517,7 +538,7 @@ namespace Implab { void InvokeHandler(HandlerDescriptor handler) { switch (m_state) { - case ResolvedState: + case SucceededState: handler.Resolve(m_result); break; case RejectedState: @@ -538,8 +559,6 @@ namespace Implab { InvokeHandler(handler); } - - public bool IsExclusive { get { return m_childrenCount <= 1; @@ -560,5 +579,68 @@ namespace Implab { } } + /// + /// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний. + /// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено. + /// При отмене нового обещания, переданные обещания также будут отменены, если никто больше на них не подписан. + /// + /// Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным. + /// Обещание объединяющее в себе результат переданных обещаний. + /// не может быть null + public static Promise CreateComposite(IList> promises) { + if (promises == null) + throw new ArgumentNullException(); + + // создаем аккумулятор для результатов и результирующее обещание + var result = new T[promises.Count]; + var promise = new Promise(); + + // special case + if (promises.Count == 0) { + promise.Resolve(result); + return promise; + } + + int pending = promises.Count; + + for (int i = 0; i < promises.Count; i++) { + var dest = i; + + promises[i].Then( + x => { + result[dest] = x; + if(Interlocked.Decrement(ref pending) == 0) + promise.Resolve(result); + }, + e => promise.Reject(e) + ); + } + + promise.Cancelled( + () => { + foreach(var d in promises) + if(d.IsExclusive) + d.Cancel(); + } + ); + + return promise; + } + + public static Promise ResultToPromise(T result) { + var p = new Promise(); + p.Resolve(result); + return p; + } + + public static Promise ExceptionToPromise(Exception error) { + if (error == null) + throw new ArgumentNullException(); + + var p = new Promise(); + p.Reject(error); + return p; + } + } } diff --git a/Implab/TaskController.cs b/Implab/TaskController.cs --- a/Implab/TaskController.cs +++ b/Implab/TaskController.cs @@ -12,7 +12,7 @@ namespace Implab /// /// Members of this object are thread safe. /// - class TaskController: IProgressNotifier, ITaskController, ICancellable + public class TaskController: IProgressNotifier, ITaskController { readonly object m_lock; string m_message; @@ -22,6 +22,7 @@ namespace Implab bool m_cancelled; + public event EventHandler Cancelled; public event EventHandler> MessageUpdated; public event EventHandler> ProgressUpdated; public event EventHandler ProgressInit; @@ -84,7 +85,7 @@ namespace Implab } } - public bool Cancelled { + public bool IsCancelled { get { lock (m_lock) return m_cancelled; @@ -102,6 +103,13 @@ namespace Implab } } + protected virtual void OnCancelled() { + var temp = Cancelled; + if (temp != null) { + temp(this,new EventArgs()); + } + } + protected virtual void OnMessageUpdated() { var temp = MessageUpdated;