Mercurial > pub > ImplabNet
diff Implab/AbstractTask.cs @ 187:dd4a3590f9c6 ref20160224
Reworked cancelation handling, if the cancel handler isn't specified the OperationCanceledException will be handled by the error handler
Any unhandled OperationCanceledException will cause the promise cancelation
author | cin |
---|---|
date | Tue, 19 Apr 2016 17:35:20 +0300 |
parents | |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/Implab/AbstractTask.cs Tue Apr 19 17:35:20 2016 +0300 @@ -0,0 +1,45 @@ +using System; +using System.Threading; + +namespace Implab { + /// <summary> + /// Базовый класс для реализации задачь. Задача представляет собой некторое + /// действие, которое можно иницировать и обработать результат его выполнения + /// в виде обещания, для этого оно реализует интерфейс <see cref="IPromise"/>. + /// </summary> + /// <remarks> + /// Данный класс определяет стандартное поведение при обработки результатов, в частности + /// обработку <see cref="System.OperationCanceledException"/> и <see cref="PromiseTransientException"/> + /// </remarks> + public abstract class AbstractTask : AbstractPromise { + int m_cancelationLock; + + /// <summary> + /// Получает эксклюзивное право отмены задания, используется для отмены задания до начала его выполнения. + /// </summary> + /// <returns><c>true</c>, if cancelation was locked, <c>false</c> otherwise.</returns> + protected bool LockCancelation() { + return 0 == Interlocked.CompareExchange(ref m_cancelationLock, 1, 0); + } + + + + protected void SetErrorInternal(Exception error) { + // unwrap + while (error is PromiseTransientException && error.InnerException != null) + error = error.InnerException; + + if (error is OperationCanceledException) + SetCancelled(error); + else + SetError(error); + } + + protected void SetCancelledInternal(Exception reason) { + SetCancelled( + reason == null ? new OperationCanceledException() : reason is OperationCanceledException ? reason : new OperationCanceledException(null, reason) + ); + } + } +} +