Promise.cs
762 lines
| 32.0 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / Promise.cs
cin
|
r2 | using System; | ||
using System.Collections.Generic; | ||||
using System.Reflection; | ||||
using System.Diagnostics; | ||||
using System.Threading; | ||||
cin
|
r19 | using Implab.Parallels; | ||
cin
|
r2 | |||
namespace Implab { | ||||
cin
|
r6 | public delegate void ErrorHandler(Exception e); | ||
cin
|
r11 | public delegate T ErrorHandler<out T>(Exception e); | ||
cin
|
r10 | public delegate void ResultHandler<in T>(T result); | ||
public delegate TNew ResultMapper<in TSrc, out TNew>(TSrc result); | ||||
cin
|
r33 | public delegate IPromise<TNew> ChainedOperation<in TSrc, TNew>(TSrc result); | ||
cin
|
r2 | |||
cin
|
r6 | /// <summary> | ||
/// Класс для асинхронного получения результатов. Так называемое "обещание". | ||||
/// </summary> | ||||
/// <typeparam name="T">Тип получаемого результата</typeparam> | ||||
/// <remarks> | ||||
/// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции, | ||||
/// клиент получив такое обещание может установить ряд обратных вызово для получения | ||||
/// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para> | ||||
/// <para> | ||||
/// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на | ||||
/// данные события клиент должен использовать методы <c>Then</c>. | ||||
/// </para> | ||||
/// <para> | ||||
/// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой), | ||||
/// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о | ||||
/// выполнении обещания. | ||||
/// </para> | ||||
/// <para> | ||||
/// Если сервер успел выполнить обещание еще до того, как клиент на него подписался, | ||||
/// то в момент подписки клиента будут вызваны соответсвующие события в синхронном | ||||
/// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в | ||||
/// список в порядке подписания и в этом же порядке они будут вызваны при выполнении | ||||
/// обещания. | ||||
/// </para> | ||||
/// <para> | ||||
/// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать | ||||
/// связанные асинхронные операции, которые также возвращают обещания. Для этого следует | ||||
/// использовать соответствующую форму методе <c>Then</c>. | ||||
/// </para> | ||||
/// <para> | ||||
/// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать | ||||
/// только инициатор обещания иначе могут возникнуть противоречия. | ||||
/// </para> | ||||
/// </remarks> | ||||
cin
|
r25 | public class Promise<T> : IPromise<T> { | ||
cin
|
r2 | |||
cin
|
r28 | protected struct HandlerDescriptor { | ||
cin
|
r6 | public ResultHandler<T> resultHandler; | ||
public ErrorHandler errorHandler; | ||||
cin
|
r19 | public Action cancellHandler; | ||
public void Resolve(T result) { | ||||
if (resultHandler != null) | ||||
try { | ||||
resultHandler(result); | ||||
} catch (Exception e) { | ||||
Reject(e); | ||||
} | ||||
} | ||||
public void Reject(Exception err) { | ||||
if (errorHandler != null) | ||||
try { | ||||
errorHandler(err); | ||||
} catch { | ||||
} | ||||
} | ||||
public void Cancel() { | ||||
if (cancellHandler != null) | ||||
try { | ||||
cancellHandler(); | ||||
} catch { | ||||
} | ||||
} | ||||
cin
|
r6 | } | ||
cin
|
r19 | const int UnresolvedSate = 0; | ||
const int TransitionalState = 1; | ||||
cin
|
r25 | const int SucceededState = 2; | ||
cin
|
r19 | const int RejectedState = 3; | ||
const int CancelledState = 4; | ||||
readonly bool m_cancellable; | ||||
cin
|
r9 | |||
cin
|
r10 | int m_childrenCount = 0; | ||
cin
|
r19 | int m_state; | ||
cin
|
r6 | T m_result; | ||
Exception m_error; | ||||
cin
|
r9 | |||
cin
|
r19 | readonly MTQueue<HandlerDescriptor> m_handlers = new MTQueue<HandlerDescriptor>(); | ||
cin
|
r6 | public Promise() { | ||
m_cancellable = true; | ||||
} | ||||
cin
|
r2 | |||
cin
|
r66 | public Promise(IPromise parent, bool cancellable) { | ||
cin
|
r7 | m_cancellable = cancellable; | ||
cin
|
r33 | if (parent != null) | ||
AddHandler( | ||||
null, | ||||
null, | ||||
() => { | ||||
if (parent.IsExclusive) | ||||
parent.Cancel(); | ||||
} | ||||
); | ||||
cin
|
r10 | } | ||
cin
|
r2 | |||
cin
|
r19 | bool BeginTransit() { | ||
return UnresolvedSate == Interlocked.CompareExchange(ref m_state, TransitionalState, UnresolvedSate); | ||||
} | ||||
void CompleteTransit(int state) { | ||||
if (TransitionalState != Interlocked.CompareExchange(ref m_state, state, TransitionalState)) | ||||
throw new InvalidOperationException("Can't complete transition when the object isn't in the transitional state"); | ||||
} | ||||
cin
|
r25 | void WaitTransition() { | ||
while (m_state == TransitionalState) { | ||||
/* noop */ | ||||
} | ||||
} | ||||
cin
|
r19 | public bool IsResolved { | ||
get { | ||||
return m_state > 1; | ||||
} | ||||
} | ||||
public bool IsCancelled { | ||||
get { | ||||
return m_state == CancelledState; | ||||
} | ||||
} | ||||
cin
|
r29 | public Type PromiseType { | ||
get { return typeof(T); } | ||||
} | ||||
cin
|
r6 | /// <summary> | ||
/// Выполняет обещание, сообщая об успешном выполнении. | ||||
/// </summary> | ||||
/// <param name="result">Результат выполнения.</param> | ||||
/// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception> | ||||
public void Resolve(T result) { | ||||
cin
|
r19 | if (BeginTransit()) { | ||
cin
|
r6 | m_result = result; | ||
cin
|
r25 | CompleteTransit(SucceededState); | ||
cin
|
r19 | OnStateChanged(); | ||
cin
|
r25 | } else { | ||
WaitTransition(); | ||||
if (m_state != CancelledState) | ||||
throw new InvalidOperationException("The promise is already resolved"); | ||||
} | ||||
cin
|
r6 | } | ||
cin
|
r2 | |||
cin
|
r6 | /// <summary> | ||
cin
|
r33 | /// Выполняет обещание, сообщая об успешном выполнении. Результатом выполнения будет пустое значения. | ||
/// </summary> | ||||
/// <remarks> | ||||
/// Данный вариант удобен в случаях, когда интересен факт выполнения операции, нежели полученное значение. | ||||
/// </remarks> | ||||
public void Resolve() { | ||||
Resolve(default(T)); | ||||
} | ||||
/// <summary> | ||||
cin
|
r6 | /// Выполняет обещание, сообщая об ошибке | ||
/// </summary> | ||||
cin
|
r16 | /// <remarks> | ||
/// Поскольку обещание должно работать в многопточной среде, при его выполнении сразу несколько потоков | ||||
/// могу вернуть ошибку, при этом только первая будет использована в качестве результата, остальные | ||||
/// будут проигнорированы. | ||||
/// </remarks> | ||||
cin
|
r6 | /// <param name="error">Исключение возникшее при выполнении операции</param> | ||
/// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception> | ||||
public void Reject(Exception error) { | ||||
cin
|
r19 | if (BeginTransit()) { | ||
cin
|
r6 | m_error = error; | ||
cin
|
r19 | CompleteTransit(RejectedState); | ||
OnStateChanged(); | ||||
cin
|
r25 | } else { | ||
WaitTransition(); | ||||
if (m_state == SucceededState) | ||||
throw new InvalidOperationException("The promise is already resolved"); | ||||
} | ||||
cin
|
r6 | } | ||
cin
|
r2 | |||
cin
|
r6 | /// <summary> | ||
/// Отменяет операцию, если это возможно. | ||||
/// </summary> | ||||
/// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns> | ||||
public bool Cancel() { | ||||
cin
|
r33 | if (BeginTransit()) { | ||
CompleteTransit(CancelledState); | ||||
OnStateChanged(); | ||||
return true; | ||||
} else { | ||||
return false; | ||||
} | ||||
} | ||||
// сделано для возвращаемого типа void | ||||
protected void InternalCancel() { | ||||
Cancel(); | ||||
cin
|
r6 | } | ||
cin
|
r2 | |||
cin
|
r6 | /// <summary> | ||
cin
|
r11 | /// Adds new handlers to this promise. | ||
cin
|
r6 | /// </summary> | ||
cin
|
r11 | /// <param name="success">The handler of the successfully completed operation. | ||
/// This handler will recieve an operation result as a parameter.</param> | ||||
/// <param name="error">Handles an exception that may occur during the operation.</param> | ||||
/// <returns>The new promise chained to this one.</returns> | ||||
cin
|
r26 | public IPromise<T> Then(ResultHandler<T> success, ErrorHandler error) { | ||
cin
|
r6 | if (success == null && error == null) | ||
return this; | ||||
cin
|
r11 | var medium = new Promise<T>(this, true); | ||
cin
|
r6 | |||
cin
|
r19 | ResultHandler<T> resultHandler; | ||
cin
|
r6 | if (success != null) | ||
cin
|
r19 | resultHandler = x => { | ||
cin
|
r10 | success(x); | ||
medium.Resolve(x); | ||||
cin
|
r6 | }; | ||
else | ||||
cin
|
r19 | resultHandler = medium.Resolve; | ||
cin
|
r2 | |||
cin
|
r19 | ErrorHandler errorHandler; | ||
cin
|
r6 | if (error != null) | ||
cin
|
r19 | errorHandler = x => { | ||
cin
|
r25 | // несмотря на то, что обработчик ошибки вызывается безопасно, | ||
// т.е. возникшие в нем ошибки будут подавлены, нам нужно | ||||
// гарантировать, что ошибка будет передана дальше по цепочке обещаний | ||||
cin
|
r6 | try { | ||
error(x); | ||||
} catch { } | ||||
medium.Reject(x); | ||||
}; | ||||
else | ||||
cin
|
r19 | errorHandler = medium.Reject; | ||
cin
|
r2 | |||
cin
|
r19 | AddHandler(resultHandler, errorHandler, medium.InternalCancel); | ||
cin
|
r2 | |||
cin
|
r6 | return medium; | ||
} | ||||
cin
|
r2 | |||
cin
|
r66 | public IPromise Then(Action success, ErrorHandler error) { | ||
cin
|
r26 | return Then(x => success(), error); | ||
} | ||||
cin
|
r66 | public IPromise Then(Action success) { | ||
cin
|
r32 | return Then(x => success()); | ||
cin
|
r26 | } | ||
cin
|
r11 | /// <summary> | ||
/// Adds new handlers to this promise. | ||||
/// </summary> | ||||
/// <param name="success">The handler of the successfully completed operation. | ||||
/// This handler will recieve an operation result as a parameter.</param> | ||||
/// <param name="error">Handles an exception that may occur during the operation and returns the value which will be used as the result of the operation.</param> | ||||
/// <returns>The new promise chained to this one.</returns> | ||||
cin
|
r26 | public IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error) { | ||
cin
|
r11 | if (success == null && error == null) | ||
return this; | ||||
var medium = new Promise<T>(this, true); | ||||
cin
|
r19 | ResultHandler<T> resultHandler; | ||
ErrorHandler errorHandler; | ||||
cin
|
r11 | |||
if (success != null) | ||||
cin
|
r19 | resultHandler = x => { | ||
cin
|
r11 | success(x); | ||
medium.Resolve(x); | ||||
}; | ||||
else | ||||
cin
|
r19 | resultHandler = medium.Resolve; | ||
cin
|
r11 | |||
if (error != null) | ||||
cin
|
r19 | errorHandler = x => { | ||
cin
|
r11 | try { | ||
medium.Resolve(error(x)); | ||||
cin
|
r33 | } catch (Exception e) { | ||
cin
|
r25 | medium.Reject(e); | ||
} | ||||
cin
|
r11 | }; | ||
else | ||||
cin
|
r19 | errorHandler = medium.Reject; | ||
cin
|
r11 | |||
cin
|
r19 | AddHandler(resultHandler, errorHandler, medium.InternalCancel); | ||
cin
|
r11 | |||
return medium; | ||||
} | ||||
cin
|
r26 | public IPromise<T> Then(ResultHandler<T> success) { | ||
cin
|
r11 | if (success == null) | ||
return this; | ||||
var medium = new Promise<T>(this, true); | ||||
cin
|
r19 | ResultHandler<T> resultHandler; | ||
cin
|
r25 | |||
cin
|
r11 | if (success != null) | ||
cin
|
r19 | resultHandler = x => { | ||
cin
|
r11 | success(x); | ||
medium.Resolve(x); | ||||
}; | ||||
else | ||||
cin
|
r19 | resultHandler = medium.Resolve; | ||
cin
|
r11 | |||
cin
|
r19 | AddHandler(resultHandler, medium.Reject, medium.InternalCancel); | ||
cin
|
r11 | |||
return medium; | ||||
cin
|
r6 | } | ||
cin
|
r2 | |||
cin
|
r26 | public IPromise<T> Error(ErrorHandler error) { | ||
return Then((ResultHandler<T>)null, error); | ||||
cin
|
r6 | } | ||
cin
|
r2 | |||
cin
|
r11 | /// <summary> | ||
/// Handles error and allows to keep the promise. | ||||
/// </summary> | ||||
/// <remarks> | ||||
/// If the specified handler throws an exception, this exception will be used to reject the promise. | ||||
/// </remarks> | ||||
/// <param name="handler">The error handler which returns the result of the promise.</param> | ||||
/// <returns>New promise.</returns> | ||||
cin
|
r26 | public IPromise<T> Error(ErrorHandler<T> handler) { | ||
cin
|
r11 | if (handler == null) | ||
return this; | ||||
var medium = new Promise<T>(this, true); | ||||
cin
|
r19 | AddHandler( | ||
cin
|
r27 | x => medium.Resolve(x), | ||
cin
|
r19 | e => { | ||
cin
|
r11 | try { | ||
medium.Resolve(handler(e)); | ||||
} catch (Exception e2) { | ||||
medium.Reject(e2); | ||||
} | ||||
cin
|
r19 | }, | ||
medium.InternalCancel | ||||
); | ||||
cin
|
r11 | |||
return medium; | ||||
} | ||||
cin
|
r26 | public IPromise<T> Anyway(Action handler) { | ||
cin
|
r6 | if (handler == null) | ||
return this; | ||||
cin
|
r33 | var medium = new Promise<T>(this,true); | ||
cin
|
r2 | |||
cin
|
r19 | AddHandler( | ||
x => { | ||||
cin
|
r10 | // to avoid handler being called multiple times we handle exception by ourselfs | ||
cin
|
r6 | try { | ||
handler(); | ||||
medium.Resolve(x); | ||||
} catch (Exception e) { | ||||
medium.Reject(e); | ||||
} | ||||
}, | ||||
cin
|
r19 | |||
e => { | ||||
cin
|
r6 | try { | ||
handler(); | ||||
} catch { } | ||||
cin
|
r19 | medium.Reject(e); | ||
}, | ||||
medium.InternalCancel | ||||
); | ||||
cin
|
r2 | |||
cin
|
r6 | return medium; | ||
} | ||||
cin
|
r2 | |||
cin
|
r6 | /// <summary> | ||
/// Позволяет преобразовать результат выполения операции к новому типу. | ||||
/// </summary> | ||||
/// <typeparam name="TNew">Новый тип результата.</typeparam> | ||||
/// <param name="mapper">Преобразование результата к новому типу.</param> | ||||
/// <param name="error">Обработчик ошибки. Данный обработчик получит | ||||
/// исключение возникшее при выполнении операции.</param> | ||||
/// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns> | ||||
cin
|
r26 | public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler error) { | ||
cin
|
r6 | if (mapper == null) | ||
throw new ArgumentNullException("mapper"); | ||||
cin
|
r2 | |||
cin
|
r6 | // создаем прицепленное обещание | ||
cin
|
r33 | var chained = new Promise<TNew>(this,true); | ||
cin
|
r2 | |||
cin
|
r19 | ResultHandler<T> resultHandler = result => chained.Resolve(mapper(result)); | ||
ErrorHandler errorHandler = delegate(Exception e) { | ||||
if (error != null) | ||||
try { | ||||
error(e); | ||||
} catch { } | ||||
// в случае ошибки нужно передать исключение дальше по цепочке | ||||
chained.Reject(e); | ||||
}; | ||||
AddHandler( | ||||
resultHandler, | ||||
errorHandler, | ||||
chained.InternalCancel | ||||
); | ||||
cin
|
r2 | |||
cin
|
r6 | return chained; | ||
} | ||||
cin
|
r26 | public IPromise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) { | ||
cin
|
r6 | return Map(mapper, null); | ||
} | ||||
cin
|
r2 | |||
cin
|
r6 | /// <summary> | ||
/// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после | ||||
/// выполнения текущей, а результат текущей операции может быть использован для инициализации | ||||
/// новой операции. | ||||
/// </summary> | ||||
/// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam> | ||||
/// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param> | ||||
/// <param name="error">Обработчик ошибки. Данный обработчик получит | ||||
/// исключение возникшее при выполнении текуещй операции.</param> | ||||
/// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns> | ||||
cin
|
r26 | public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler error) { | ||
cin
|
r6 | |||
// проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно | ||||
// создать посредника, к которому будут подвызяваться следующие обработчики. | ||||
// когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы | ||||
// передать через него результаты работы. | ||||
cin
|
r10 | var medium = new Promise<TNew>(this, true); | ||
cin
|
r2 | |||
cin
|
r19 | ResultHandler<T> resultHandler = delegate(T result) { | ||
if (medium.IsCancelled) | ||||
return; | ||||
cin
|
r10 | |||
cin
|
r19 | var promise = chained(result); | ||
cin
|
r10 | |||
cin
|
r19 | promise.Then( | ||
x => medium.Resolve(x), | ||||
e => medium.Reject(e) | ||||
); | ||||
cin
|
r33 | |||
// notify chained operation that it's not needed anymore | ||||
// порядок вызова Then, Cancelled важен, поскольку от этого | ||||
// зависит IsExclusive | ||||
medium.Cancelled(() => { | ||||
if(promise.IsExclusive) | ||||
promise.Cancel(); | ||||
}); | ||||
// внешняя отмена связанной операции рассматривается как ошибка | ||||
promise.Cancelled(() => medium.Reject(new OperationCanceledException())); | ||||
cin
|
r19 | }; | ||
ErrorHandler errorHandler = delegate(Exception e) { | ||||
if (error != null) | ||||
error(e); | ||||
// в случае ошибки нужно передать исключение дальше по цепочке | ||||
medium.Reject(e); | ||||
}; | ||||
AddHandler( | ||||
resultHandler, | ||||
errorHandler, | ||||
medium.InternalCancel | ||||
); | ||||
cin
|
r2 | |||
cin
|
r6 | return medium; | ||
} | ||||
cin
|
r26 | public IPromise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) { | ||
cin
|
r6 | return Chain(chained, null); | ||
} | ||||
cin
|
r2 | |||
cin
|
r26 | public IPromise<T> Cancelled(Action handler) { | ||
cin
|
r19 | AddHandler(null, null, handler); | ||
cin
|
r10 | return this; | ||
} | ||||
cin
|
r25 | /// <summary> | ||
/// Adds the specified handler for all cases (success, error, cancel) | ||||
/// </summary> | ||||
/// <param name="handler">The handler that will be called anyway</param> | ||||
/// <returns>self</returns> | ||||
cin
|
r26 | public IPromise<T> Finally(Action handler) { | ||
cin
|
r19 | if (handler == null) | ||
throw new ArgumentNullException("handler"); | ||||
AddHandler( | ||||
x => handler(), | ||||
e => handler(), | ||||
handler | ||||
); | ||||
return this; | ||||
cin
|
r10 | } | ||
cin
|
r6 | /// <summary> | ||
cin
|
r29 | /// Преобразует результат обещания к нужному типу | ||
/// </summary> | ||||
/// <typeparam name="T2"></typeparam> | ||||
/// <returns></returns> | ||||
public IPromise<T2> Cast<T2>() { | ||||
return Map(x => (T2)(object)x, null); | ||||
} | ||||
/// <summary> | ||||
cin
|
r6 | /// Дожидается отложенного обещания и в случае успеха, возвращает | ||
/// его, результат, в противном случае бросает исключение. | ||||
/// </summary> | ||||
/// <remarks> | ||||
/// <para> | ||||
/// Если ожидание обещания было прервано по таймауту, это не значит, | ||||
/// что обещание было отменено или что-то в этом роде, это только | ||||
/// означает, что мы его не дождались, однако все зарегистрированные | ||||
/// обработчики, как были так остались и они будут вызваны, когда | ||||
/// обещание будет выполнено. | ||||
/// </para> | ||||
/// <para> | ||||
/// Такое поведение вполне оправдано поскольку таймаут может истечь | ||||
/// в тот момент, когда началась обработка цепочки обработчиков, и | ||||
/// к тому же текущее обещание может стоять в цепочке обещаний и его | ||||
/// отклонение может привести к непрогнозируемому результату. | ||||
/// </para> | ||||
/// </remarks> | ||||
/// <param name="timeout">Время ожидания</param> | ||||
/// <returns>Результат выполнения обещания</returns> | ||||
public T Join(int timeout) { | ||||
cin
|
r10 | var evt = new ManualResetEvent(false); | ||
cin
|
r6 | Anyway(() => evt.Set()); | ||
cin
|
r10 | Cancelled(() => evt.Set()); | ||
cin
|
r2 | |||
cin
|
r6 | if (!evt.WaitOne(timeout, true)) | ||
throw new TimeoutException(); | ||||
cin
|
r2 | |||
cin
|
r19 | switch (m_state) { | ||
cin
|
r25 | case SucceededState: | ||
cin
|
r10 | return m_result; | ||
cin
|
r19 | case CancelledState: | ||
cin
|
r10 | throw new OperationCanceledException(); | ||
cin
|
r19 | case RejectedState: | ||
cin
|
r10 | throw new TargetInvocationException(m_error); | ||
default: | ||||
cin
|
r19 | throw new ApplicationException(String.Format("Invalid promise state {0}", m_state)); | ||
cin
|
r10 | } | ||
cin
|
r6 | } | ||
public T Join() { | ||||
return Join(Timeout.Infinite); | ||||
} | ||||
cin
|
r2 | |||
cin
|
r19 | void AddHandler(ResultHandler<T> success, ErrorHandler error, Action cancel) { | ||
cin
|
r33 | if (success != null || error != null) | ||
Interlocked.Increment(ref m_childrenCount); | ||||
cin
|
r19 | |||
HandlerDescriptor handler = new HandlerDescriptor { | ||||
resultHandler = success, | ||||
errorHandler = error, | ||||
cancellHandler = cancel | ||||
}; | ||||
cin
|
r2 | |||
cin
|
r19 | bool queued; | ||
if (!IsResolved) { | ||||
m_handlers.Enqueue(handler); | ||||
queued = true; | ||||
} else { | ||||
// the promise is in resolved state, just invoke the handled with minimum overhead | ||||
queued = false; | ||||
InvokeHandler(handler); | ||||
cin
|
r6 | } | ||
cin
|
r2 | |||
cin
|
r19 | if (queued && IsResolved && m_handlers.TryDequeue(out handler)) | ||
// if the promise have been resolved while we was adding handler to the queue | ||||
// we can't guarantee that someone is still processing it | ||||
// therefore we will fetch a handler from the queue and execute it | ||||
cin
|
r27 | // note that fetched handler may be not the one that we have added | ||
// even we can fetch no handlers at all :) | ||||
cin
|
r6 | InvokeHandler(handler); | ||
} | ||||
cin
|
r2 | |||
cin
|
r27 | protected virtual void InvokeHandler(HandlerDescriptor handler) { | ||
cin
|
r10 | switch (m_state) { | ||
cin
|
r25 | case SucceededState: | ||
cin
|
r19 | handler.Resolve(m_result); | ||
cin
|
r10 | break; | ||
cin
|
r19 | case RejectedState: | ||
handler.Reject(m_error); | ||||
break; | ||||
case CancelledState: | ||||
handler.Cancel(); | ||||
cin
|
r10 | break; | ||
default: | ||||
// do nothing | ||||
return; | ||||
cin
|
r6 | } | ||
} | ||||
cin
|
r2 | |||
cin
|
r65 | void OnStateChanged() { | ||
cin
|
r19 | HandlerDescriptor handler; | ||
while (m_handlers.TryDequeue(out handler)) | ||||
InvokeHandler(handler); | ||||
cin
|
r11 | } | ||
cin
|
r9 | public bool IsExclusive { | ||
get { | ||||
cin
|
r19 | return m_childrenCount <= 1; | ||
cin
|
r9 | } | ||
} | ||||
cin
|
r25 | /// <summary> | ||
/// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний. | ||||
/// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено. | ||||
/// При отмене нового обещания, переданные обещания также будут отменены, если никто больше на них не подписан. | ||||
/// </summary> | ||||
/// <param name="promises">Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным.</param> | ||||
/// <returns>Обещание объединяющее в себе результат переданных обещаний.</returns> | ||||
/// <exception cref="ArgumentNullException"><paramref name="promises"/> не может быть null</exception> | ||||
cin
|
r30 | public static IPromise<T[]> CreateComposite(IList<IPromise<T>> promises) { | ||
cin
|
r25 | if (promises == null) | ||
throw new ArgumentNullException(); | ||||
// создаем аккумулятор для результатов и результирующее обещание | ||||
var result = new T[promises.Count]; | ||||
var promise = new Promise<T[]>(); | ||||
// 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; | ||||
cin
|
r33 | if (promises[i] != null) { | ||
promises[i].Then( | ||||
x => { | ||||
result[dest] = x; | ||||
if (Interlocked.Decrement(ref pending) == 0) | ||||
promise.Resolve(result); | ||||
}, | ||||
e => promise.Reject(e) | ||||
); | ||||
} else { | ||||
if (Interlocked.Decrement(ref pending) == 0) | ||||
promise.Resolve(result); | ||||
} | ||||
cin
|
r25 | } | ||
promise.Cancelled( | ||||
() => { | ||||
cin
|
r33 | foreach (var d in promises) | ||
if (d != null && d.IsExclusive) | ||||
cin
|
r25 | d.Cancel(); | ||
} | ||||
); | ||||
return promise; | ||||
} | ||||
cin
|
r33 | /// <summary> | ||
/// Объединяет несколько обещаний в одно. Результирующее обещание будет выполнено при | ||||
/// выполнении всех указанных обещаний. При этом возвращаемые значения первичных обещаний | ||||
/// игнорируются. | ||||
/// </summary> | ||||
/// <param name="promises">Коллекция первичных обещаний, которые будут объеденены в одно.</param> | ||||
/// <returns>Новое обещание, объединяющее в себе переданные.</returns> | ||||
/// <remarks> | ||||
/// Если в коллекции встречаюься <c>null</c>, то они воспринимаются как выполненные обещания. | ||||
/// </remarks> | ||||
cin
|
r66 | public static IPromise CreateComposite(ICollection<IPromise> promises) { | ||
cin
|
r33 | if (promises == null) | ||
throw new ArgumentNullException(); | ||||
if (promises.Count == 0) | ||||
return Promise<object>.ResultToPromise(null); | ||||
int countdown = promises.Count; | ||||
var result = new Promise<object>(); | ||||
foreach (var d in promises) { | ||||
if (d == null) { | ||||
if (Interlocked.Decrement(ref countdown) == 0) | ||||
result.Resolve(null); | ||||
} else { | ||||
d.Then(() => { | ||||
if (Interlocked.Decrement(ref countdown) == 0) | ||||
result.Resolve(null); | ||||
}); | ||||
} | ||||
} | ||||
result.Cancelled(() => { | ||||
foreach (var d in promises) | ||||
if (d != null && d.IsExclusive) | ||||
d.Cancel(); | ||||
}); | ||||
return result; | ||||
} | ||||
cin
|
r25 | public static Promise<T> ResultToPromise(T result) { | ||
var p = new Promise<T>(); | ||||
p.Resolve(result); | ||||
return p; | ||||
} | ||||
public static Promise<T> ExceptionToPromise(Exception error) { | ||||
if (error == null) | ||||
throw new ArgumentNullException(); | ||||
var p = new Promise<T>(); | ||||
p.Reject(error); | ||||
return p; | ||||
} | ||||
cin
|
r33 | #region IPromiseBase explicit implementation | ||
cin
|
r66 | IPromise IPromise.Error(ErrorHandler error) { | ||
cin
|
r33 | return Error(error); | ||
} | ||||
cin
|
r66 | IPromise IPromise.Anyway(Action handler) { | ||
cin
|
r33 | return Anyway(handler); | ||
} | ||||
cin
|
r66 | IPromise IPromise.Finally(Action handler) { | ||
cin
|
r33 | return Finally(handler); | ||
} | ||||
cin
|
r66 | IPromise IPromise.Cancelled(Action handler) { | ||
cin
|
r33 | return Cancelled(handler); | ||
} | ||||
cin
|
r66 | void IPromise.Join() { | ||
cin
|
r33 | Join(); | ||
} | ||||
cin
|
r66 | void IPromise.Join(int timeout) { | ||
cin
|
r33 | Join(timeout); | ||
} | ||||
#endregion | ||||
cin
|
r6 | } | ||
cin
|
r2 | } | ||