Mercurial > pub > ImplabNet

annotate Implab/Promise.cs @ 17:7cd4a843b4e4 promises

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Improved worker pool
author cin
date Fri, 08 Nov 2013 01:25:42 +0400
parents 5a4b735ba669
children e3935fdf59a2
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
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
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
cin
parents: 7
diff changeset
57
cin
parents: 7
diff changeset
58 LinkedList<ResultHandlerInfo> m_resultHandlers = new LinkedList<ResultHandlerInfo>();
cin
parents: 7
diff changeset
59 LinkedList<Action> m_cancelHandlers = new LinkedList<Action>();
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
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
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
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>
16
cin
parents: 15
diff changeset
106 /// <remarks>
cin
parents: 15
diff changeset
107 /// Поскольку обещание должно работать в многопточной среде, при его выполнении сразу несколько потоков
cin
parents: 15
diff changeset
108 /// могу вернуть ошибку, при этом только первая будет использована в качестве результата, остальные
cin
parents: 15
diff changeset
109 /// будут проигнорированы.
cin
parents: 15
diff changeset
110 /// </remarks>
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
111 /// <param name="error">Исключение возникшее при выполнении операции</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
112 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
113 public void Reject(Exception error) {
14
e943453e5039 Implemented interllocked queue
cin
parents: 11
diff changeset
114 lock (m_lock) {
16
cin
parents: 15
diff changeset
115 if (m_state == PromiseState.Cancelled || m_state == PromiseState.Rejected)
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
116 return;
7
7ea9363fef6c inital progress handling
cin
parents: 6
diff changeset
117 if (m_state != PromiseState.Unresolved)
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
118 throw new InvalidOperationException("The promise is already resolved");
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
119 m_error = error;
7
7ea9363fef6c inital progress handling
cin
parents: 6
diff changeset
120 m_state = PromiseState.Rejected;
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
121 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
122
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
123 OnStateChanged();
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
124 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
125
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
126 /// <summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
127 /// Отменяет операцию, если это возможно.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
128 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
129 /// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
130 public bool Cancel() {
9
cin
parents: 7
diff changeset
131 return Cancel(true);
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
132 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
133
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
134 /// <summary>
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
135 /// Adds new handlers to this promise.
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
136 /// </summary>
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
137 /// <param name="success">The handler of the successfully completed operation.
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
138 /// This handler will recieve an operation result as a parameter.</param>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
139 /// <param name="error">Handles an exception that may occur during the operation.</param>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
140 /// <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
141 public Promise<T> Then(ResultHandler<T> success, ErrorHandler error) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
142 if (success == null && error == null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
143 return this;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
144
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
145 var medium = new Promise<T>(this, true);
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
146
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
147 var handlerInfo = new ResultHandlerInfo();
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 if (success != null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
150 handlerInfo.resultHandler = x => {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
151 success(x);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
152 medium.Resolve(x);
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
153 };
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
154 else
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
155 handlerInfo.resultHandler = medium.Resolve;
2
aa367305156b small fixes
cin
parents: 1
diff changeset
156
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
157 if (error != null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
158 handlerInfo.errorHandler = x => {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
159 try {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
160 error(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
161 } catch { }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
162 medium.Reject(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
163 };
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
164 else
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
165 handlerInfo.errorHandler = medium.Reject;
2
aa367305156b small fixes
cin
parents: 1
diff changeset
166
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
167 AddHandler(handlerInfo);
2
aa367305156b small fixes
cin
parents: 1
diff changeset
168
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
169 return medium;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
170 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
171
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
172 /// <summary>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
173 /// Adds new handlers to this promise.
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
174 /// </summary>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
175 /// <param name="success">The handler of the successfully completed operation.
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
176 /// This handler will recieve an operation result as a parameter.</param>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
177 /// <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
178 /// <returns>The new promise chained to this one.</returns>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
179 public Promise<T> Then(ResultHandler<T> success, ErrorHandler<T> error) {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
180 if (success == null && error == null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
181 return this;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
182
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
183 var medium = new Promise<T>(this, true);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
184
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
185 var handlerInfo = new ResultHandlerInfo();
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
186
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
187 if (success != null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
188 handlerInfo.resultHandler = x => {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
189 success(x);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
190 medium.Resolve(x);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
191 };
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
192 else
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
193 handlerInfo.resultHandler = medium.Resolve;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
194
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
195 if (error != null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
196 handlerInfo.errorHandler = x => {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
197 try {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
198 medium.Resolve(error(x));
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
199 } catch { }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
200 medium.Reject(x);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
201 };
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
202 else
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
203 handlerInfo.errorHandler = medium.Reject;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
204
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
205 AddHandler(handlerInfo);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
206
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
207 return medium;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
208 }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
209
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
210
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
211 public Promise<T> Then(ResultHandler<T> success) {
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
212 if (success == null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
213 return this;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
214
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
215 var medium = new Promise<T>(this, true);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
216
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
217 var handlerInfo = new ResultHandlerInfo();
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
218
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
219 if (success != null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
220 handlerInfo.resultHandler = x => {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
221 success(x);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
222 medium.Resolve(x);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
223 };
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
224 else
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
225 handlerInfo.resultHandler = medium.Resolve;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
226
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
227 handlerInfo.errorHandler = medium.Reject;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
228
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
229 AddHandler(handlerInfo);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
230
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
231 return medium;
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
232 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
233
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
234 public Promise<T> Error(ErrorHandler error) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
235 return Then(null, error);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
236 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
237
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
238 /// <summary>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
239 /// Handles error and allows to keep the promise.
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
240 /// </summary>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
241 /// <remarks>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
242 /// If the specified handler throws an exception, this exception will be used to reject the promise.
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
243 /// </remarks>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
244 /// <param name="handler">The error handler which returns the result of the promise.</param>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
245 /// <returns>New promise.</returns>
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
246 public Promise<T> Error(ErrorHandler<T> handler) {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
247 if (handler == null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
248 return this;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
249
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
250 var medium = new Promise<T>(this, true);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
251
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
252 AddHandler(new ResultHandlerInfo {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
253 errorHandler = e => {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
254 try {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
255 medium.Resolve(handler(e));
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
256 } catch (Exception e2) {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
257 medium.Reject(e2);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
258 }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
259 }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
260 });
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
261
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
262 return medium;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
263 }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
264
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
265 public Promise<T> Anyway(Action handler) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
266 if (handler == null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
267 return this;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
268
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
269 var medium = new Promise<T>();
2
aa367305156b small fixes
cin
parents: 1
diff changeset
270
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
271 AddHandler(new ResultHandlerInfo {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
272 resultHandler = x => {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
273 // 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
274 try {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
275 handler();
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
276 medium.Resolve(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
277 } catch (Exception e) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
278 medium.Reject(e);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
279 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
280 },
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
281 errorHandler = x => {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
282 try {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
283 handler();
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
284 } catch { }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
285 medium.Reject(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
286 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
287 });
2
aa367305156b small fixes
cin
parents: 1
diff changeset
288
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
289 return medium;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
290 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
291
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
292 /// <summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
293 /// Позволяет преобразовать результат выполения операции к новому типу.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
294 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
295 /// <typeparam name="TNew">Новый тип результата.</typeparam>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
296 /// <param name="mapper">Преобразование результата к новому типу.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
297 /// <param name="error">Обработчик ошибки. Данный обработчик получит
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
298 /// исключение возникшее при выполнении операции.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
299 /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
300 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
301 if (mapper == null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
302 throw new ArgumentNullException("mapper");
2
aa367305156b small fixes
cin
parents: 1
diff changeset
303
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
304 // создаем прицепленное обещание
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
305 var chained = new Promise<TNew>();
2
aa367305156b small fixes
cin
parents: 1
diff changeset
306
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
307 AddHandler(new ResultHandlerInfo() {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
308 resultHandler = result => chained.Resolve(mapper(result)),
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
309 errorHandler = delegate(Exception e) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
310 if (error != null)
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
311 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
312 error(e);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
313 } catch { }
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
314 // в случае ошибки нужно передать исключение дальше по цепочке
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
315 chained.Reject(e);
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 });
2
aa367305156b small fixes
cin
parents: 1
diff changeset
318
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
319 return chained;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
320 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
321
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
322 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
323 return Map(mapper, null);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
324 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
325
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
326 /// <summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
327 /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
328 /// выполнения текущей, а результат текущей операции может быть использован для инициализации
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
329 /// новой операции.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
330 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
331 /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
332 /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
333 /// <param name="error">Обработчик ошибки. Данный обработчик получит
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
334 /// исключение возникшее при выполнении текуещй операции.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
335 /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
336 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
337
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
338 // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
339 // создать посредника, к которому будут подвызяваться следующие обработчики.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
340 // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
341 // передать через него результаты работы.
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
342 var medium = new Promise<TNew>(this, true);
2
aa367305156b small fixes
cin
parents: 1
diff changeset
343
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
344 AddHandler(new ResultHandlerInfo {
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
345 resultHandler = delegate(T result) {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
346 if (medium.State == PromiseState.Cancelled)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
347 return;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
348
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
349 var promise = chained(result);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
350
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
351 // notify chained operation that it's not needed
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
352 medium.Cancelled(() => promise.Cancel());
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
353 promise.Then(
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
354 x => medium.Resolve(x),
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
355 e => medium.Reject(e)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
356 );
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
357 },
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
358 errorHandler = delegate(Exception e) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
359 if (error != null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
360 error(e);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
361 // в случае ошибки нужно передать исключение дальше по цепочке
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
362 medium.Reject(e);
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 });
2
aa367305156b small fixes
cin
parents: 1
diff changeset
365
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
366 return medium;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
367 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
368
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
369 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
370 return Chain(chained, null);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
371 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
372
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
373 public Promise<T> Cancelled(Action handler) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
374 if (handler == null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
375 return this;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
376 lock (m_lock) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
377 if (m_state == PromiseState.Unresolved)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
378 m_cancelHandlers.AddLast(handler);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
379 else if (m_state == PromiseState.Cancelled)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
380 handler();
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
381 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
382 return this;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
383 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
384
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
385 public void HandleCancelled(Action handler) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
386 Cancelled(handler);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
387 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
388
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
389 /// <summary>
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 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
393 /// <remarks>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
394 /// <para>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
395 /// Если ожидание обещания было прервано по таймауту, это не значит,
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
396 /// что обещание было отменено или что-то в этом роде, это только
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 /// </para>
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 /// Такое поведение вполне оправдано поскольку таймаут может истечь
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
403 /// в тот момент, когда началась обработка цепочки обработчиков, и
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
404 /// к тому же текущее обещание может стоять в цепочке обещаний и его
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
405 /// отклонение может привести к непрогнозируемому результату.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
406 /// </para>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
407 /// </remarks>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
408 /// <param name="timeout">Время ожидания</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
409 /// <returns>Результат выполнения обещания</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
410 public T Join(int timeout) {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
411 var evt = new ManualResetEvent(false);
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
412 Anyway(() => evt.Set());
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
413 Cancelled(() => evt.Set());
2
aa367305156b small fixes
cin
parents: 1
diff changeset
414
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
415 if (!evt.WaitOne(timeout, true))
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
416 throw new TimeoutException();
2
aa367305156b small fixes
cin
parents: 1
diff changeset
417
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
418 switch (State) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
419 case PromiseState.Resolved:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
420 return m_result;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
421 case PromiseState.Cancelled:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
422 throw new OperationCanceledException();
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
423 case PromiseState.Rejected:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
424 throw new TargetInvocationException(m_error);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
425 default:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
426 throw new ApplicationException(String.Format("Invalid promise state {0}", State));
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
427 }
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
428 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
429
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
430 public T Join() {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
431 return Join(Timeout.Infinite);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
432 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
433
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
434 void AddHandler(ResultHandlerInfo handler) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
435 bool invokeRequired = false;
2
aa367305156b small fixes
cin
parents: 1
diff changeset
436
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
437 lock (m_lock) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
438 m_childrenCount++;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
439 if (m_state == PromiseState.Unresolved) {
9
cin
parents: 7
diff changeset
440 m_resultHandlers.AddLast(handler);
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
441 } else
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
442 invokeRequired = true;
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 // обработчики не должны блокировать сам объект
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
446 if (invokeRequired)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
447 InvokeHandler(handler);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
448 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
449
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
450 void InvokeHandler(ResultHandlerInfo handler) {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
451 switch (m_state) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
452 case PromiseState.Resolved:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
453 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
454 if (handler.resultHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
455 handler.resultHandler(m_result);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
456 } catch (Exception e) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
457 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
458 if (handler.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
459 handler.errorHandler(e);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
460 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
461 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
462 break;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
463 case PromiseState.Rejected:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
464 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
465 if (handler.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
466 handler.errorHandler(m_error);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
467 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
468 break;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
469 default:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
470 // do nothing
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
471 return;
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
472 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
473 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
474
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
475 protected virtual void OnStateChanged() {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
476 switch (m_state) {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
477 case PromiseState.Resolved:
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
478 foreach (var resultHandlerInfo in m_resultHandlers)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
479 try {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
480 if (resultHandlerInfo.resultHandler != null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
481 resultHandlerInfo.resultHandler(m_result);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
482 } catch (Exception e) {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
483 try {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
484 if (resultHandlerInfo.errorHandler != null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
485 resultHandlerInfo.errorHandler(e);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
486 } catch { }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
487 }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
488 break;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
489 case PromiseState.Cancelled:
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
490 foreach (var cancelHandler in m_cancelHandlers)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
491 cancelHandler();
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
492 break;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
493 case PromiseState.Rejected:
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
494 foreach (var resultHandlerInfo in m_resultHandlers)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
495 try {
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
496 if (resultHandlerInfo.errorHandler != null)
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
497 resultHandlerInfo.errorHandler(m_error);
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
498 } catch { }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
499 break;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
500 default:
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
501 throw new InvalidOperationException(String.Format("Promise entered an invalid state {0}", m_state));
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
502 }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
503
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
504 m_resultHandlers = null;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
505 m_cancelHandlers = null;
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
506 }
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
507
2
aa367305156b small fixes
cin
parents: 1
diff changeset
508
9
cin
parents: 7
diff changeset
509
cin
parents: 7
diff changeset
510 public bool IsExclusive {
cin
parents: 7
diff changeset
511 get {
cin
parents: 7
diff changeset
512 lock (m_lock) {
cin
parents: 7
diff changeset
513 return m_childrenCount <= 1;
cin
parents: 7
diff changeset
514 }
cin
parents: 7
diff changeset
515 }
cin
parents: 7
diff changeset
516 }
cin
parents: 7
diff changeset
517
cin
parents: 7
diff changeset
518 public PromiseState State {
cin
parents: 7
diff changeset
519 get {
cin
parents: 7
diff changeset
520 lock (m_lock) {
cin
parents: 7
diff changeset
521 return m_state;
cin
parents: 7
diff changeset
522 }
cin
parents: 7
diff changeset
523 }
cin
parents: 7
diff changeset
524 }
cin
parents: 7
diff changeset
525
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
526 protected bool Cancel(bool dependencies) {
9
cin
parents: 7
diff changeset
527 bool result;
cin
parents: 7
diff changeset
528
cin
parents: 7
diff changeset
529 lock (m_lock) {
cin
parents: 7
diff changeset
530 if (m_state == PromiseState.Unresolved) {
cin
parents: 7
diff changeset
531 m_state = PromiseState.Cancelled;
cin
parents: 7
diff changeset
532 result = true;
cin
parents: 7
diff changeset
533 } else {
cin
parents: 7
diff changeset
534 result = false;
cin
parents: 7
diff changeset
535 }
cin
parents: 7
diff changeset
536 }
cin
parents: 7
diff changeset
537
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
538 if (result)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
539 OnStateChanged();
9
cin
parents: 7
diff changeset
540
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
541 if (dependencies && m_parent != null && m_parent.IsExclusive) {
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
542 m_parent.Cancel();
9
cin
parents: 7
diff changeset
543 }
cin
parents: 7
diff changeset
544
cin
parents: 7
diff changeset
545 return result;
cin
parents: 7
diff changeset
546 }
15
0f982f9b7d4d implemented parallel map and foreach for arrays
cin
parents: 14
diff changeset
547
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
548 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
549 }