pub/ImplabNet: Implab/Promise.cs annotate

annotate Implab/Promise.cs @ 15:0f982f9b7d4d promises

implemented parallel map and foreach for arrays rewritten WorkerPool with MTQueue for more efficiency

author	cin
date	Thu, 07 Nov 2013 03:41:32 +0400
parents	e943453e5039
children	5a4b735ba669

rev	line source
2 aa367305156b small fixes cin parents: 1 diff changeset	1 using System;
aa367305156b small fixes cin parents: 1 diff changeset	2 using System.Collections.Generic;
aa367305156b small fixes cin parents: 1 diff changeset	3 using System.Reflection;
aa367305156b small fixes cin parents: 1 diff changeset	4 using System.Diagnostics;
aa367305156b small fixes cin parents: 1 diff changeset	5 using System.Threading;
aa367305156b small fixes cin parents: 1 diff changeset	6
aa367305156b small fixes cin parents: 1 diff changeset	7 namespace Implab {
aa367305156b small fixes cin parents: 1 diff changeset	8
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	9 public delegate void ErrorHandler(Exception e);
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	10 public delegate T ErrorHandler<out T>(Exception e);
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	11 public delegate void ResultHandler<in T>(T result);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	12 public delegate TNew ResultMapper<in TSrc, out TNew>(TSrc result);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	13 public delegate Promise<TNew> ChainedOperation<in TSrc, TNew>(TSrc result);
2 aa367305156b small fixes cin parents: 1 diff changeset	14
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	15 /// <summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	16 /// Класс для асинхронного получения результатов. Так называемое "обещание".
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	17 /// </summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	18 /// <typeparam name="T">Тип получаемого результата</typeparam>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	19 /// <remarks>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	20 /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	21 /// клиент получив такое обещание может установить ряд обратных вызово для получения
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	22 /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	23 /// <para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	24 /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	25 /// данные события клиент должен использовать методы <c>Then</c>.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	26 /// </para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	27 /// <para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	28 /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	29 /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	30 /// выполнении обещания.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	31 /// </para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	32 /// <para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	33 /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	34 /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	35 /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	36 /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	37 /// обещания.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	38 /// </para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	39 /// <para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	40 /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	41 /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	42 /// использовать соответствующую форму методе <c>Then</c>.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	43 /// </para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	44 /// <para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	45 /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	46 /// только инициатор обещания иначе могут возникнуть противоречия.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	47 /// </para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	48 /// </remarks>
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	49 public class Promise<T> : IPromise {
2 aa367305156b small fixes cin parents: 1 diff changeset	50
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	51 struct ResultHandlerInfo {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	52 public ResultHandler<T> resultHandler;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	53 public ErrorHandler errorHandler;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	54 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	55
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	56 readonly IPromise m_parent;
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	57
c82e0dfbb4dd sync cin parents: 7 diff changeset	58 LinkedList<ResultHandlerInfo> m_resultHandlers = new LinkedList<ResultHandlerInfo>();
c82e0dfbb4dd sync cin parents: 7 diff changeset	59 LinkedList<Action> m_cancelHandlers = new LinkedList<Action>();
c82e0dfbb4dd sync cin parents: 7 diff changeset	60
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	61 readonly object m_lock = new Object();
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	62 readonly bool m_cancellable;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	63 int m_childrenCount = 0;
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	64
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	65 PromiseState m_state;
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	66 T m_result;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	67 Exception m_error;
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	68
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	69 public Promise() {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	70 m_cancellable = true;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	71 }
2 aa367305156b small fixes cin parents: 1 diff changeset	72
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	73 public Promise(IPromise parent, bool cancellable) {
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	74 m_cancellable = cancellable;
7ea9363fef6c inital progress handling cin parents: 6 diff changeset	75 m_parent = parent;
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	76 if (parent != null)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	77 parent.HandleCancelled(InternalCancel);
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	78 }
7ea9363fef6c inital progress handling cin parents: 6 diff changeset	79
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	80 void InternalCancel() {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	81 // don't try to cancel parent :)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	82 Cancel(false);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	83 }
2 aa367305156b small fixes cin parents: 1 diff changeset	84
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	85 /// <summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	86 /// Выполняет обещание, сообщая об успешном выполнении.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	87 /// </summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	88 /// <param name="result">Результат выполнения.</param>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	89 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	90 public void Resolve(T result) {
14 e943453e5039 Implemented interllocked queue cin parents: 11 diff changeset	91 lock (m_lock) {
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	92 if (m_state == PromiseState.Cancelled)
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	93 return;
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	94 if (m_state != PromiseState.Unresolved)
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	95 throw new InvalidOperationException("The promise is already resolved");
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	96 m_result = result;
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	97 m_state = PromiseState.Resolved;
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	98 }
2 aa367305156b small fixes cin parents: 1 diff changeset	99
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	100 OnStateChanged();
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	101 }
2 aa367305156b small fixes cin parents: 1 diff changeset	102
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	103 /// <summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	104 /// Выполняет обещание, сообщая об ошибке
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	105 /// </summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	106 /// <param name="error">Исключение возникшее при выполнении операции</param>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	107 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	108 public void Reject(Exception error) {
14 e943453e5039 Implemented interllocked queue cin parents: 11 diff changeset	109 lock (m_lock) {
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	110 if (m_state == PromiseState.Cancelled)
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	111 return;
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	112 if (m_state != PromiseState.Unresolved)
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	113 throw new InvalidOperationException("The promise is already resolved");
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	114 m_error = error;
7 7ea9363fef6c inital progress handling cin parents: 6 diff changeset	115 m_state = PromiseState.Rejected;
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	116 }
2 aa367305156b small fixes cin parents: 1 diff changeset	117
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	118 OnStateChanged();
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	119 }
2 aa367305156b small fixes cin parents: 1 diff changeset	120
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	121 /// <summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	122 /// Отменяет операцию, если это возможно.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	123 /// </summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	124 /// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	125 public bool Cancel() {
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	126 return Cancel(true);
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	127 }
2 aa367305156b small fixes cin parents: 1 diff changeset	128
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	129 /// <summary>
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	130 /// Adds new handlers to this promise.
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	131 /// </summary>
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	132 /// <param name="success">The handler of the successfully completed operation.
6ec82bf68c8e refactoring cin parents: 10 diff changeset	133 /// This handler will recieve an operation result as a parameter.</param>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	134 /// <param name="error">Handles an exception that may occur during the operation.</param>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	135 /// <returns>The new promise chained to this one.</returns>
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	136 public Promise<T> Then(ResultHandler<T> success, ErrorHandler error) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	137 if (success == null && error == null)
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	138 return this;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	139
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	140 var medium = new Promise<T>(this, true);
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	141
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	142 var handlerInfo = new ResultHandlerInfo();
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	143
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	144 if (success != null)
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	145 handlerInfo.resultHandler = x => {
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	146 success(x);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	147 medium.Resolve(x);
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	148 };
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	149 else
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	150 handlerInfo.resultHandler = medium.Resolve;
2 aa367305156b small fixes cin parents: 1 diff changeset	151
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	152 if (error != null)
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	153 handlerInfo.errorHandler = x => {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	154 try {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	155 error(x);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	156 } catch { }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	157 medium.Reject(x);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	158 };
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	159 else
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	160 handlerInfo.errorHandler = medium.Reject;
2 aa367305156b small fixes cin parents: 1 diff changeset	161
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	162 AddHandler(handlerInfo);
2 aa367305156b small fixes cin parents: 1 diff changeset	163
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	164 return medium;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	165 }
2 aa367305156b small fixes cin parents: 1 diff changeset	166
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	167 /// <summary>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	168 /// Adds new handlers to this promise.
6ec82bf68c8e refactoring cin parents: 10 diff changeset	169 /// </summary>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	170 /// <param name="success">The handler of the successfully completed operation.
6ec82bf68c8e refactoring cin parents: 10 diff changeset	171 /// This handler will recieve an operation result as a parameter.</param>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	172 /// <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>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	173 /// <returns>The new promise chained to this one.</returns>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	174 public Promise<T> Then(ResultHandler<T> success, ErrorHandler<T> error) {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	175 if (success == null && error == null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	176 return this;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	177
6ec82bf68c8e refactoring cin parents: 10 diff changeset	178 var medium = new Promise<T>(this, true);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	179
6ec82bf68c8e refactoring cin parents: 10 diff changeset	180 var handlerInfo = new ResultHandlerInfo();
6ec82bf68c8e refactoring cin parents: 10 diff changeset	181
6ec82bf68c8e refactoring cin parents: 10 diff changeset	182 if (success != null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	183 handlerInfo.resultHandler = x => {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	184 success(x);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	185 medium.Resolve(x);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	186 };
6ec82bf68c8e refactoring cin parents: 10 diff changeset	187 else
6ec82bf68c8e refactoring cin parents: 10 diff changeset	188 handlerInfo.resultHandler = medium.Resolve;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	189
6ec82bf68c8e refactoring cin parents: 10 diff changeset	190 if (error != null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	191 handlerInfo.errorHandler = x => {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	192 try {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	193 medium.Resolve(error(x));
6ec82bf68c8e refactoring cin parents: 10 diff changeset	194 } catch { }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	195 medium.Reject(x);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	196 };
6ec82bf68c8e refactoring cin parents: 10 diff changeset	197 else
6ec82bf68c8e refactoring cin parents: 10 diff changeset	198 handlerInfo.errorHandler = medium.Reject;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	199
6ec82bf68c8e refactoring cin parents: 10 diff changeset	200 AddHandler(handlerInfo);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	201
6ec82bf68c8e refactoring cin parents: 10 diff changeset	202 return medium;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	203 }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	204
6ec82bf68c8e refactoring cin parents: 10 diff changeset	205
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	206 public Promise<T> Then(ResultHandler<T> success) {
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	207 if (success == null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	208 return this;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	209
6ec82bf68c8e refactoring cin parents: 10 diff changeset	210 var medium = new Promise<T>(this, true);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	211
6ec82bf68c8e refactoring cin parents: 10 diff changeset	212 var handlerInfo = new ResultHandlerInfo();
6ec82bf68c8e refactoring cin parents: 10 diff changeset	213
6ec82bf68c8e refactoring cin parents: 10 diff changeset	214 if (success != null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	215 handlerInfo.resultHandler = x => {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	216 success(x);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	217 medium.Resolve(x);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	218 };
6ec82bf68c8e refactoring cin parents: 10 diff changeset	219 else
6ec82bf68c8e refactoring cin parents: 10 diff changeset	220 handlerInfo.resultHandler = medium.Resolve;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	221
6ec82bf68c8e refactoring cin parents: 10 diff changeset	222 handlerInfo.errorHandler = medium.Reject;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	223
6ec82bf68c8e refactoring cin parents: 10 diff changeset	224 AddHandler(handlerInfo);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	225
6ec82bf68c8e refactoring cin parents: 10 diff changeset	226 return medium;
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	227 }
2 aa367305156b small fixes cin parents: 1 diff changeset	228
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	229 public Promise<T> Error(ErrorHandler error) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	230 return Then(null, error);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	231 }
2 aa367305156b small fixes cin parents: 1 diff changeset	232
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	233 /// <summary>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	234 /// Handles error and allows to keep the promise.
6ec82bf68c8e refactoring cin parents: 10 diff changeset	235 /// </summary>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	236 /// <remarks>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	237 /// If the specified handler throws an exception, this exception will be used to reject the promise.
6ec82bf68c8e refactoring cin parents: 10 diff changeset	238 /// </remarks>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	239 /// <param name="handler">The error handler which returns the result of the promise.</param>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	240 /// <returns>New promise.</returns>
6ec82bf68c8e refactoring cin parents: 10 diff changeset	241 public Promise<T> Error(ErrorHandler<T> handler) {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	242 if (handler == null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	243 return this;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	244
6ec82bf68c8e refactoring cin parents: 10 diff changeset	245 var medium = new Promise<T>(this, true);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	246
6ec82bf68c8e refactoring cin parents: 10 diff changeset	247 AddHandler(new ResultHandlerInfo {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	248 errorHandler = e => {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	249 try {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	250 medium.Resolve(handler(e));
6ec82bf68c8e refactoring cin parents: 10 diff changeset	251 } catch (Exception e2) {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	252 medium.Reject(e2);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	253 }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	254 }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	255 });
6ec82bf68c8e refactoring cin parents: 10 diff changeset	256
6ec82bf68c8e refactoring cin parents: 10 diff changeset	257 return medium;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	258 }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	259
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	260 public Promise<T> Anyway(Action handler) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	261 if (handler == null)
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	262 return this;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	263
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	264 var medium = new Promise<T>();
2 aa367305156b small fixes cin parents: 1 diff changeset	265
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	266 AddHandler(new ResultHandlerInfo {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	267 resultHandler = x => {
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	268 // to avoid handler being called multiple times we handle exception by ourselfs
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	269 try {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	270 handler();
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	271 medium.Resolve(x);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	272 } catch (Exception e) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	273 medium.Reject(e);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	274 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	275 },
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	276 errorHandler = x => {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	277 try {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	278 handler();
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	279 } catch { }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	280 medium.Reject(x);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	281 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	282 });
2 aa367305156b small fixes cin parents: 1 diff changeset	283
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	284 return medium;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	285 }
2 aa367305156b small fixes cin parents: 1 diff changeset	286
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	287 /// <summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	288 /// Позволяет преобразовать результат выполения операции к новому типу.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	289 /// </summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	290 /// <typeparam name="TNew">Новый тип результата.</typeparam>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	291 /// <param name="mapper">Преобразование результата к новому типу.</param>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	292 /// <param name="error">Обработчик ошибки. Данный обработчик получит
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	293 /// исключение возникшее при выполнении операции.</param>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	294 /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	295 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler error) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	296 if (mapper == null)
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	297 throw new ArgumentNullException("mapper");
2 aa367305156b small fixes cin parents: 1 diff changeset	298
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	299 // создаем прицепленное обещание
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	300 var chained = new Promise<TNew>();
2 aa367305156b small fixes cin parents: 1 diff changeset	301
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	302 AddHandler(new ResultHandlerInfo() {
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	303 resultHandler = result => chained.Resolve(mapper(result)),
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	304 errorHandler = delegate(Exception e) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	305 if (error != null)
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	306 try {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	307 error(e);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	308 } catch { }
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	309 // в случае ошибки нужно передать исключение дальше по цепочке
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	310 chained.Reject(e);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	311 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	312 });
2 aa367305156b small fixes cin parents: 1 diff changeset	313
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	314 return chained;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	315 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	316
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	317 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	318 return Map(mapper, null);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	319 }
2 aa367305156b small fixes cin parents: 1 diff changeset	320
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	321 /// <summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	322 /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	323 /// выполнения текущей, а результат текущей операции может быть использован для инициализации
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	324 /// новой операции.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	325 /// </summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	326 /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	327 /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	328 /// <param name="error">Обработчик ошибки. Данный обработчик получит
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	329 /// исключение возникшее при выполнении текуещй операции.</param>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	330 /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	331 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler error) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	332
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	333 // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	334 // создать посредника, к которому будут подвызяваться следующие обработчики.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	335 // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	336 // передать через него результаты работы.
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	337 var medium = new Promise<TNew>(this, true);
2 aa367305156b small fixes cin parents: 1 diff changeset	338
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	339 AddHandler(new ResultHandlerInfo {
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	340 resultHandler = delegate(T result) {
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	341 if (medium.State == PromiseState.Cancelled)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	342 return;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	343
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	344 var promise = chained(result);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	345
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	346 // notify chained operation that it's not needed
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	347 medium.Cancelled(() => promise.Cancel());
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	348 promise.Then(
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	349 x => medium.Resolve(x),
6ec82bf68c8e refactoring cin parents: 10 diff changeset	350 e => medium.Reject(e)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	351 );
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	352 },
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	353 errorHandler = delegate(Exception e) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	354 if (error != null)
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	355 error(e);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	356 // в случае ошибки нужно передать исключение дальше по цепочке
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	357 medium.Reject(e);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	358 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	359 });
2 aa367305156b small fixes cin parents: 1 diff changeset	360
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	361 return medium;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	362 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	363
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	364 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	365 return Chain(chained, null);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	366 }
2 aa367305156b small fixes cin parents: 1 diff changeset	367
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	368 public Promise<T> Cancelled(Action handler) {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	369 if (handler == null)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	370 return this;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	371 lock (m_lock) {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	372 if (m_state == PromiseState.Unresolved)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	373 m_cancelHandlers.AddLast(handler);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	374 else if (m_state == PromiseState.Cancelled)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	375 handler();
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	376 }
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	377 return this;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	378 }
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	379
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	380 public void HandleCancelled(Action handler) {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	381 Cancelled(handler);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	382 }
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	383
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	384 /// <summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	385 /// Дожидается отложенного обещания и в случае успеха, возвращает
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	386 /// его, результат, в противном случае бросает исключение.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	387 /// </summary>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	388 /// <remarks>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	389 /// <para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	390 /// Если ожидание обещания было прервано по таймауту, это не значит,
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	391 /// что обещание было отменено или что-то в этом роде, это только
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	392 /// означает, что мы его не дождались, однако все зарегистрированные
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	393 /// обработчики, как были так остались и они будут вызваны, когда
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	394 /// обещание будет выполнено.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	395 /// </para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	396 /// <para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	397 /// Такое поведение вполне оправдано поскольку таймаут может истечь
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	398 /// в тот момент, когда началась обработка цепочки обработчиков, и
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	399 /// к тому же текущее обещание может стоять в цепочке обещаний и его
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	400 /// отклонение может привести к непрогнозируемому результату.
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	401 /// </para>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	402 /// </remarks>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	403 /// <param name="timeout">Время ожидания</param>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	404 /// <returns>Результат выполнения обещания</returns>
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	405 public T Join(int timeout) {
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	406 var evt = new ManualResetEvent(false);
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	407 Anyway(() => evt.Set());
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	408 Cancelled(() => evt.Set());
2 aa367305156b small fixes cin parents: 1 diff changeset	409
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	410 if (!evt.WaitOne(timeout, true))
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	411 throw new TimeoutException();
2 aa367305156b small fixes cin parents: 1 diff changeset	412
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	413 switch (State) {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	414 case PromiseState.Resolved:
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	415 return m_result;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	416 case PromiseState.Cancelled:
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	417 throw new OperationCanceledException();
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	418 case PromiseState.Rejected:
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	419 throw new TargetInvocationException(m_error);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	420 default:
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	421 throw new ApplicationException(String.Format("Invalid promise state {0}", State));
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	422 }
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	423 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	424
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	425 public T Join() {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	426 return Join(Timeout.Infinite);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	427 }
2 aa367305156b small fixes cin parents: 1 diff changeset	428
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	429 void AddHandler(ResultHandlerInfo handler) {
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	430 bool invokeRequired = false;
2 aa367305156b small fixes cin parents: 1 diff changeset	431
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	432 lock (m_lock) {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	433 m_childrenCount++;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	434 if (m_state == PromiseState.Unresolved) {
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	435 m_resultHandlers.AddLast(handler);
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	436 } else
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	437 invokeRequired = true;
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	438 }
2 aa367305156b small fixes cin parents: 1 diff changeset	439
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	440 // обработчики не должны блокировать сам объект
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	441 if (invokeRequired)
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	442 InvokeHandler(handler);
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	443 }
2 aa367305156b small fixes cin parents: 1 diff changeset	444
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	445 void InvokeHandler(ResultHandlerInfo handler) {
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	446 switch (m_state) {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	447 case PromiseState.Resolved:
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	448 try {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	449 if (handler.resultHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	450 handler.resultHandler(m_result);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	451 } catch (Exception e) {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	452 try {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	453 if (handler.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	454 handler.errorHandler(e);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	455 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	456 }
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	457 break;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	458 case PromiseState.Rejected:
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	459 try {
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	460 if (handler.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	461 handler.errorHandler(m_error);
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	462 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	463 break;
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	464 default:
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	465 // do nothing
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	466 return;
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	467 }
dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	468 }
2 aa367305156b small fixes cin parents: 1 diff changeset	469
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	470 protected virtual void OnStateChanged() {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	471 switch (m_state) {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	472 case PromiseState.Resolved:
6ec82bf68c8e refactoring cin parents: 10 diff changeset	473 foreach (var resultHandlerInfo in m_resultHandlers)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	474 try {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	475 if (resultHandlerInfo.resultHandler != null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	476 resultHandlerInfo.resultHandler(m_result);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	477 } catch (Exception e) {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	478 try {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	479 if (resultHandlerInfo.errorHandler != null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	480 resultHandlerInfo.errorHandler(e);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	481 } catch { }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	482 }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	483 break;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	484 case PromiseState.Cancelled:
6ec82bf68c8e refactoring cin parents: 10 diff changeset	485 foreach (var cancelHandler in m_cancelHandlers)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	486 cancelHandler();
6ec82bf68c8e refactoring cin parents: 10 diff changeset	487 break;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	488 case PromiseState.Rejected:
6ec82bf68c8e refactoring cin parents: 10 diff changeset	489 foreach (var resultHandlerInfo in m_resultHandlers)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	490 try {
6ec82bf68c8e refactoring cin parents: 10 diff changeset	491 if (resultHandlerInfo.errorHandler != null)
6ec82bf68c8e refactoring cin parents: 10 diff changeset	492 resultHandlerInfo.errorHandler(m_error);
6ec82bf68c8e refactoring cin parents: 10 diff changeset	493 } catch { }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	494 break;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	495 default:
6ec82bf68c8e refactoring cin parents: 10 diff changeset	496 throw new InvalidOperationException(String.Format("Promise entered an invalid state {0}", m_state));
6ec82bf68c8e refactoring cin parents: 10 diff changeset	497 }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	498
6ec82bf68c8e refactoring cin parents: 10 diff changeset	499 m_resultHandlers = null;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	500 m_cancelHandlers = null;
6ec82bf68c8e refactoring cin parents: 10 diff changeset	501 }
6ec82bf68c8e refactoring cin parents: 10 diff changeset	502
2 aa367305156b small fixes cin parents: 1 diff changeset	503
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	504
c82e0dfbb4dd sync cin parents: 7 diff changeset	505 public bool IsExclusive {
c82e0dfbb4dd sync cin parents: 7 diff changeset	506 get {
c82e0dfbb4dd sync cin parents: 7 diff changeset	507 lock (m_lock) {
c82e0dfbb4dd sync cin parents: 7 diff changeset	508 return m_childrenCount <= 1;
c82e0dfbb4dd sync cin parents: 7 diff changeset	509 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	510 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	511 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	512
c82e0dfbb4dd sync cin parents: 7 diff changeset	513 public PromiseState State {
c82e0dfbb4dd sync cin parents: 7 diff changeset	514 get {
c82e0dfbb4dd sync cin parents: 7 diff changeset	515 lock (m_lock) {
c82e0dfbb4dd sync cin parents: 7 diff changeset	516 return m_state;
c82e0dfbb4dd sync cin parents: 7 diff changeset	517 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	518 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	519 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	520
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	521 protected bool Cancel(bool dependencies) {
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	522 bool result;
c82e0dfbb4dd sync cin parents: 7 diff changeset	523
c82e0dfbb4dd sync cin parents: 7 diff changeset	524 lock (m_lock) {
c82e0dfbb4dd sync cin parents: 7 diff changeset	525 if (m_state == PromiseState.Unresolved) {
c82e0dfbb4dd sync cin parents: 7 diff changeset	526 m_state = PromiseState.Cancelled;
c82e0dfbb4dd sync cin parents: 7 diff changeset	527 result = true;
c82e0dfbb4dd sync cin parents: 7 diff changeset	528 } else {
c82e0dfbb4dd sync cin parents: 7 diff changeset	529 result = false;
c82e0dfbb4dd sync cin parents: 7 diff changeset	530 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	531 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	532
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	533 if (result)
aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	534 OnStateChanged();
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	535
10 aa33d0bb8c0c implemeted new cancellable promises concept cin parents: 9 diff changeset	536 if (dependencies && m_parent != null && m_parent.IsExclusive) {
11 6ec82bf68c8e refactoring cin parents: 10 diff changeset	537 m_parent.Cancel();
9 c82e0dfbb4dd sync cin parents: 7 diff changeset	538 }
c82e0dfbb4dd sync cin parents: 7 diff changeset	539
c82e0dfbb4dd sync cin parents: 7 diff changeset	540 return result;
c82e0dfbb4dd sync cin parents: 7 diff changeset	541 }
15 0f982f9b7d4d implemented parallel map and foreach for arrays cin parents: 14 diff changeset	542
6 dfa21d507bc5 refactoring: Promise.Then now returns a new chained promise cin* parents: 2 diff changeset	543 }
2 aa367305156b small fixes cin parents: 1 diff changeset	544 }

Mercurial > pub > ImplabNet

annotate Implab/Promise.cs @ 15:0f982f9b7d4d promises