Mercurial > pub > ImplabNet

annotate Implab/Promise.cs @ 14:e943453e5039 promises

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Implemented interllocked queue fixed promise syncronization
author cin
date Wed, 06 Nov 2013 17:49:12 +0400
parents 6ec82bf68c8e
children 0f982f9b7d4d
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>
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
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
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
cin
parents: 7
diff changeset
504
cin
parents: 7
diff changeset
505 public bool IsExclusive {
cin
parents: 7
diff changeset
506 get {
cin
parents: 7
diff changeset
507 lock (m_lock) {
cin
parents: 7
diff changeset
508 return m_childrenCount <= 1;
cin
parents: 7
diff changeset
509 }
cin
parents: 7
diff changeset
510 }
cin
parents: 7
diff changeset
511 }
cin
parents: 7
diff changeset
512
cin
parents: 7
diff changeset
513 public PromiseState State {
cin
parents: 7
diff changeset
514 get {
cin
parents: 7
diff changeset
515 lock (m_lock) {
cin
parents: 7
diff changeset
516 return m_state;
cin
parents: 7
diff changeset
517 }
cin
parents: 7
diff changeset
518 }
cin
parents: 7
diff changeset
519 }
cin
parents: 7
diff changeset
520
11
6ec82bf68c8e refactoring
cin
parents: 10
diff changeset
521 protected bool Cancel(bool dependencies) {
9
cin
parents: 7
diff changeset
522 bool result;
cin
parents: 7
diff changeset
523
cin
parents: 7
diff changeset
524 lock (m_lock) {
cin
parents: 7
diff changeset
525 if (m_state == PromiseState.Unresolved) {
cin
parents: 7
diff changeset
526 m_state = PromiseState.Cancelled;
cin
parents: 7
diff changeset
527 result = true;
cin
parents: 7
diff changeset
528 } else {
cin
parents: 7
diff changeset
529 result = false;
cin
parents: 7
diff changeset
530 }
cin
parents: 7
diff changeset
531 }
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
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
cin
parents: 7
diff changeset
538 }
cin
parents: 7
diff changeset
539
cin
parents: 7
diff changeset
540 return result;
cin
parents: 7
diff changeset
541 }
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
542 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
543 }