Mercurial > pub > ImplabNet

annotate Implab/Promise.cs @ 10:aa33d0bb8c0c promises

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
implemeted new cancellable promises concept
author cin
date Sun, 03 Nov 2013 18:07:38 +0400
parents c82e0dfbb4dd
children 6ec82bf68c8e
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);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
10
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) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
91 lock (this) {
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) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
109 lock (this) {
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
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
129 protected virtual void OnStateChanged() {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
130 switch (m_state) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
131 case PromiseState.Resolved:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
132 foreach (var resultHandlerInfo in m_resultHandlers)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
133 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
134 if (resultHandlerInfo.resultHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
135 resultHandlerInfo.resultHandler(m_result);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
136 } catch (Exception e) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
137 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
138 if (resultHandlerInfo.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
139 resultHandlerInfo.errorHandler(e);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
140 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
141 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
142 break;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
143 case PromiseState.Cancelled:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
144 foreach (var cancelHandler in m_cancelHandlers)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
145 cancelHandler();
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
146 break;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
147 case PromiseState.Rejected:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
148 foreach (var resultHandlerInfo in m_resultHandlers)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
149 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
150 if (resultHandlerInfo.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
151 resultHandlerInfo.errorHandler(m_error);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
152 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
153 break;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
154 default:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
155 throw new InvalidOperationException(String.Format("Promise entered an invalid state {0}", m_state));
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
156 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
157
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
158 m_resultHandlers = null;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
159 m_cancelHandlers = null;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
160 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
161
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
162 /// <summary>
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 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
165 /// <param name="success">Обработчик успешного выполнения обещания.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
166 /// Данному обработчику будет передан результат выполнения операции.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
167 /// <param name="error">Обработчик ошибки. Данный обработчик получит
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
168 /// исключение возникшее при выполнении операции.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
169 /// <returns>Само обещание</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
170 public Promise<T> Then(ResultHandler<T> success, ErrorHandler error) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
171 if (success == null && error == null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
172 return this;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
173
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
174 var medium = new Promise<T>();
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
175
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
176 var handlerInfo = new ResultHandlerInfo();
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
177
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
178 if (success != null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
179 handlerInfo.resultHandler = x => {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
180 success(x);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
181 medium.Resolve(x);
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
182 };
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
183 else
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
184 handlerInfo.resultHandler = medium.Resolve;
2
aa367305156b small fixes
cin
parents: 1
diff changeset
185
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
186 if (error != null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
187 handlerInfo.errorHandler = x => {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
188 try {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
189 error(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
190 } catch { }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
191 medium.Reject(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
192 };
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
193 else
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
194 handlerInfo.errorHandler = medium.Reject;
2
aa367305156b small fixes
cin
parents: 1
diff changeset
195
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
196 AddHandler(handlerInfo);
2
aa367305156b small fixes
cin
parents: 1
diff changeset
197
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
198 return medium;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
199 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
200
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
201 public Promise<T> Then(ResultHandler<T> success) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
202 return Then(success, null);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
203 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
204
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
205 public Promise<T> Error(ErrorHandler error) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
206 return Then(null, error);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
207 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
208
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
209 public Promise<T> Anyway(Action handler) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
210 if (handler == null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
211 return this;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
212
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
213 var medium = new Promise<T>();
2
aa367305156b small fixes
cin
parents: 1
diff changeset
214
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
215 AddHandler(new ResultHandlerInfo {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
216 resultHandler = x => {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
217 // 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
218 try {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
219 handler();
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
220 medium.Resolve(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
221 } catch (Exception e) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
222 medium.Reject(e);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
223 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
224 },
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
225 errorHandler = x => {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
226 try {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
227 handler();
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
228 } catch { }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
229 medium.Reject(x);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
230 }
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
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
233 return medium;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
234 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
235
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
236 /// <summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
237 /// Позволяет преобразовать результат выполения операции к новому типу.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
238 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
239 /// <typeparam name="TNew">Новый тип результата.</typeparam>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
240 /// <param name="mapper">Преобразование результата к новому типу.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
241 /// <param name="error">Обработчик ошибки. Данный обработчик получит
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
242 /// исключение возникшее при выполнении операции.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
243 /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
244 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
245 if (mapper == null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
246 throw new ArgumentNullException("mapper");
2
aa367305156b small fixes
cin
parents: 1
diff changeset
247
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
248 // создаем прицепленное обещание
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
249 var chained = new Promise<TNew>();
2
aa367305156b small fixes
cin
parents: 1
diff changeset
250
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
251 AddHandler(new ResultHandlerInfo() {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
252 resultHandler = result => chained.Resolve(mapper(result)),
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
253 errorHandler = delegate(Exception e) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
254 if (error != null)
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
255 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
256 error(e);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
257 } catch { }
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
258 // в случае ошибки нужно передать исключение дальше по цепочке
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
259 chained.Reject(e);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
260 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
261 });
2
aa367305156b small fixes
cin
parents: 1
diff changeset
262
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
263 return chained;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
264 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
265
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
266 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
267 return Map(mapper, null);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
268 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
269
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
270 /// <summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
271 /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
272 /// выполнения текущей, а результат текущей операции может быть использован для инициализации
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
273 /// новой операции.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
274 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
275 /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
276 /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
277 /// <param name="error">Обработчик ошибки. Данный обработчик получит
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
278 /// исключение возникшее при выполнении текуещй операции.</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
279 /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
280 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
281
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
282 // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
283 // создать посредника, к которому будут подвызяваться следующие обработчики.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
284 // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
285 // передать через него результаты работы.
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
286 var medium = new Promise<TNew>(this, true);
2
aa367305156b small fixes
cin
parents: 1
diff changeset
287
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
288 AddHandler(new ResultHandlerInfo {
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
289 resultHandler = delegate(T result) {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
290 if (medium.State == PromiseState.Cancelled)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
291 return;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
292
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
293 var promise = chained(result);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
294
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
295 // notify chained operation that it's not needed
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
296 medium.Cancelled(() => promise.Cancel());
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
297 promise.Then(
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
298 medium.Resolve,
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
299 medium.Reject
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
300 );
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
301 },
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
302 errorHandler = delegate(Exception e) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
303 if (error != null)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
304 error(e);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
305 // в случае ошибки нужно передать исключение дальше по цепочке
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
306 medium.Reject(e);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
307 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
308 });
2
aa367305156b small fixes
cin
parents: 1
diff changeset
309
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
310 return medium;
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
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
313 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
314 return Chain(chained, null);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
315 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
316
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
317 public Promise<T> Cancelled(Action handler) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
318 if (handler == null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
319 return this;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
320 lock (m_lock) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
321 if (m_state == PromiseState.Unresolved)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
322 m_cancelHandlers.AddLast(handler);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
323 else if (m_state == PromiseState.Cancelled)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
324 handler();
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
325 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
326 return this;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
327 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
328
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
329 public void HandleCancelled(Action handler) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
330 Cancelled(handler);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
331 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
332
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
333 /// <summary>
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 /// </summary>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
337 /// <remarks>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
338 /// <para>
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 /// означает, что мы его не дождались, однако все зарегистрированные
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
342 /// обработчики, как были так остались и они будут вызваны, когда
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
343 /// обещание будет выполнено.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
344 /// </para>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
345 /// <para>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
346 /// Такое поведение вполне оправдано поскольку таймаут может истечь
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
347 /// в тот момент, когда началась обработка цепочки обработчиков, и
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
348 /// к тому же текущее обещание может стоять в цепочке обещаний и его
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
349 /// отклонение может привести к непрогнозируемому результату.
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
350 /// </para>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
351 /// </remarks>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
352 /// <param name="timeout">Время ожидания</param>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
353 /// <returns>Результат выполнения обещания</returns>
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
354 public T Join(int timeout) {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
355 var evt = new ManualResetEvent(false);
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
356 Anyway(() => evt.Set());
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
357 Cancelled(() => evt.Set());
2
aa367305156b small fixes
cin
parents: 1
diff changeset
358
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
359 if (!evt.WaitOne(timeout, true))
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
360 throw new TimeoutException();
2
aa367305156b small fixes
cin
parents: 1
diff changeset
361
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
362 switch (State) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
363 case PromiseState.Resolved:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
364 return m_result;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
365 case PromiseState.Cancelled:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
366 throw new OperationCanceledException();
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
367 case PromiseState.Rejected:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
368 throw new TargetInvocationException(m_error);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
369 default:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
370 throw new ApplicationException(String.Format("Invalid promise state {0}", State));
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
371 }
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
372 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
373
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
374 public T Join() {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
375 return Join(Timeout.Infinite);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
376 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
377
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
378 void AddHandler(ResultHandlerInfo handler) {
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
379 bool invokeRequired = false;
2
aa367305156b small fixes
cin
parents: 1
diff changeset
380
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
381 lock (m_lock) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
382 m_childrenCount++;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
383 if (m_state == PromiseState.Unresolved) {
9
cin
parents: 7
diff changeset
384 m_resultHandlers.AddLast(handler);
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
385 } else
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
386 invokeRequired = true;
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
387 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
388
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
389 // обработчики не должны блокировать сам объект
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
390 if (invokeRequired)
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
391 InvokeHandler(handler);
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
392 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
393
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
394 void InvokeHandler(ResultHandlerInfo handler) {
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
395 switch (m_state) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
396 case PromiseState.Resolved:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
397 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
398 if (handler.resultHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
399 handler.resultHandler(m_result);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
400 } catch (Exception e) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
401 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
402 if (handler.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
403 handler.errorHandler(e);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
404 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
405 }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
406 break;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
407 case PromiseState.Rejected:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
408 try {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
409 if (handler.errorHandler != null)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
410 handler.errorHandler(m_error);
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
411 } catch { }
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
412 break;
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
413 default:
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
414 // do nothing
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
415 return;
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
416 }
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
417 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
418
aa367305156b small fixes
cin
parents: 1
diff changeset
419
9
cin
parents: 7
diff changeset
420
cin
parents: 7
diff changeset
421 public bool IsExclusive {
cin
parents: 7
diff changeset
422 get {
cin
parents: 7
diff changeset
423 lock (m_lock) {
cin
parents: 7
diff changeset
424 return m_childrenCount <= 1;
cin
parents: 7
diff changeset
425 }
cin
parents: 7
diff changeset
426 }
cin
parents: 7
diff changeset
427 }
cin
parents: 7
diff changeset
428
cin
parents: 7
diff changeset
429 public PromiseState State {
cin
parents: 7
diff changeset
430 get {
cin
parents: 7
diff changeset
431 lock (m_lock) {
cin
parents: 7
diff changeset
432 return m_state;
cin
parents: 7
diff changeset
433 }
cin
parents: 7
diff changeset
434 }
cin
parents: 7
diff changeset
435 }
cin
parents: 7
diff changeset
436
cin
parents: 7
diff changeset
437 public bool Cancel(bool dependencies) {
cin
parents: 7
diff changeset
438 bool result;
cin
parents: 7
diff changeset
439
cin
parents: 7
diff changeset
440 lock (m_lock) {
cin
parents: 7
diff changeset
441 if (m_state == PromiseState.Unresolved) {
cin
parents: 7
diff changeset
442 m_state = PromiseState.Cancelled;
cin
parents: 7
diff changeset
443 result = true;
cin
parents: 7
diff changeset
444 } else {
cin
parents: 7
diff changeset
445 result = false;
cin
parents: 7
diff changeset
446 }
cin
parents: 7
diff changeset
447 }
cin
parents: 7
diff changeset
448
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
449 if (result)
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
450 OnStateChanged();
9
cin
parents: 7
diff changeset
451
10
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
452 if (dependencies && m_parent != null && m_parent.IsExclusive) {
aa33d0bb8c0c implemeted new cancellable promises concept
cin
parents: 9
diff changeset
453 m_parent.Cancel(true);
9
cin
parents: 7
diff changeset
454 }
cin
parents: 7
diff changeset
455
cin
parents: 7
diff changeset
456 return result;
cin
parents: 7
diff changeset
457 }
6
dfa21d507bc5 *refactoring: Promise.Then now returns a new chained promise
cin
parents: 2
diff changeset
458 }
2
aa367305156b small fixes
cin
parents: 1
diff changeset
459 }