ActionChainTaskBase.cs
62 lines
| 2.6 KiB
| text/x-csharp
|
CSharpLexer
/ Implab / ActionChainTaskBase.cs
cin
|
r145 | using System; | ||
| using System.Threading; | ||||
| namespace Implab { | ||||
|
cin
|
r187 | public class ActionChainTaskBase : AbstractTask { | ||
|
cin
|
r145 | readonly Func<Exception, IPromise> m_error; | ||
| readonly Func<Exception, IPromise> m_cancel; | ||||
|
cin
|
r149 | protected ActionChainTaskBase(Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) { | ||
|
cin
|
r145 | m_error = error; | ||
| m_cancel = cancel; | ||||
|
cin
|
r149 | if (autoCancellable) | ||
| CancellationRequested(CancelOperation); | ||||
|
cin
|
r145 | } | ||
| public void Reject(Exception error) { | ||||
| if (LockCancelation()) | ||||
| HandleErrorInternal(error); | ||||
| } | ||||
| public override void CancelOperation(Exception reason) { | ||||
|
cin
|
r187 | if (LockCancelation()) | ||
| // отмена вызвана до начала выполнения задачи | ||||
| HandleCancelInternal(reason); | ||||
| } | ||||
| protected void HandleCancelInternal(Exception reason) { | ||||
| if (m_cancel != null) { | ||||
| try { | ||||
| // вызываем обработчик отмены | ||||
| var p = m_cancel(reason); | ||||
| p.On(SetResult, HandleErrorInternal, SetCancelledInternal); | ||||
| // сообщаем асинхронной операции, что клиент уже не хочет получать результат | ||||
| // т.е. если он инициировал отмену, задача отменилась, вызвался обрабочик отмены | ||||
| // отбработчику сообщили, что результат уже не нужен и уже сам обработчик решает | ||||
| // отдавать ли результат или подтвердить отмену (или вернуть ошибку). | ||||
| CancellationRequested(p.Cancel); | ||||
| } catch (Exception err) { | ||||
| HandleErrorInternal(err); | ||||
|
cin
|
r145 | } | ||
|
cin
|
r187 | } else { | ||
| HandleErrorInternal(reason ?? new OperationCanceledException()); | ||||
|
cin
|
r145 | } | ||
| } | ||||
|
cin
|
r187 | protected void HandleErrorInternal(Exception error) { | ||
|
cin
|
r145 | if (m_error != null) { | ||
| try { | ||||
|
cin
|
r149 | var p = m_error(error); | ||
|
cin
|
r187 | p.On(SetResult, SetErrorInternal, SetCancelledInternal); | ||
|
cin
|
r149 | CancellationRequested(p.Cancel); | ||
| } catch (Exception err) { | ||||
|
cin
|
r187 | SetErrorInternal(error); | ||
|
cin
|
r145 | } | ||
| } else { | ||||
|
cin
|
r186 | SetErrorInternal(error); | ||
| } | ||||
| } | ||||
|
cin
|
r145 | } | ||
| } | ||||