##// END OF EJS Templates
implab » ImplabNet
RSS
*refactoring: Promise.Then now returns a new chained promise...
cin -
r6:dfa21d507bc5 default
parent child
Show More
Show file before | Show file after | Hide comments
@@ -1,97 +1,97
1 using System;
1 using System;
2 using System.Collections.Generic;
2 using System.Collections.Generic;
3 using System.Linq;
3 using System.Linq;
4 using System.Text;
4 using System.Text;
5 using System.Timers;
5 using System.Timers;
6 using System.ComponentModel;
6 using System.ComponentModel;
7 using System.Diagnostics;
7 using System.Diagnostics;
8
8
9 namespace Implab.Fx
9 namespace Implab.Fx
10 {
10 {
11 public delegate void AnimationStep<T>(T target, int elapsed, int duration);
11 public delegate void AnimationStep<T>(T target, int elapsed, int duration);
12
12
13 public class Animation<TArg> where TArg: class
13 public class Animation<TArg> where TArg: class
14 {
14 {
15 int m_duration;
15 int m_duration;
16 int m_delay;
16 int m_delay;
17 int m_elapsed;
17 int m_elapsed;
18 int m_prevTicks;
18 int m_prevTicks;
19 TArg m_arg;
19 TArg m_arg;
20 ISynchronizeInvoke m_syncronizationObject;
20 ISynchronizeInvoke m_syncronizationObject;
21
21
22 public event AnimationStep<TArg> Step;
22 public event AnimationStep<TArg> Step;
23
23
24 Promise<TArg> m_promise;
24 Promise<TArg> m_promise;
25
25
26 public Animation(TArg target, int duration, int delay)
26 public Animation(TArg target, int duration, int delay)
27 {
27 {
28 if (duration <= 0)
28 if (duration <= 0)
29 throw new ArgumentOutOfRangeException("duration");
29 throw new ArgumentOutOfRangeException("duration");
30 if (delay <= 0)
30 if (delay <= 0)
31 throw new ArgumentOutOfRangeException("delay");
31 throw new ArgumentOutOfRangeException("delay");
32
32
33 m_arg = target;
33 m_arg = target;
34 m_syncronizationObject = target as ISynchronizeInvoke;
34 m_syncronizationObject = target as ISynchronizeInvoke;
35 m_duration = duration;
35 m_duration = duration;
36 m_delay = delay;
36 m_delay = delay;
37 m_promise = new Promise<TArg>();
37 m_promise = new Promise<TArg>();
38 }
38 }
39
39
40 public Animation(TArg target)
40 public Animation(TArg target)
41 : this(target, 500, 30)
41 : this(target, 500, 30)
42 {
42 {
43 }
43 }
44
44
45 public TArg Traget
45 public TArg Traget
46 {
46 {
47 get { return m_arg; }
47 get { return m_arg; }
48 }
48 }
49
49
50 public Promise<TArg> Play()
50 public Promise<TArg> Play()
51 {
51 {
52 var timer = new Timer(m_delay);
52 var timer = new Timer(m_delay);
53
53
54 timer.AutoReset = true;
54 timer.AutoReset = false;
55 timer.SynchronizingObject = m_syncronizationObject;
55 timer.SynchronizingObject = m_syncronizationObject;
56 timer.Elapsed += new ElapsedEventHandler(timer_Elapsed);
56 timer.Elapsed += new ElapsedEventHandler(timer_Elapsed);
57
57
58 m_prevTicks = Environment.TickCount;
58 m_prevTicks = Environment.TickCount;
59
59
60 timer.Start();
60 timer.Start();
61
61
62 return m_promise;
62 return m_promise;
63 }
63 }
64
64
65 void timer_Elapsed(object sender, ElapsedEventArgs args)
65 void timer_Elapsed(object sender, ElapsedEventArgs args)
66 {
66 {
67 var timer = sender as Timer;
67 var timer = sender as Timer;
68
68
69 var dt = Environment.TickCount - m_prevTicks;
69 var dt = Environment.TickCount - m_prevTicks;
70 m_prevTicks = Environment.TickCount;
70 m_prevTicks = Environment.TickCount;
71
71
72 m_elapsed += dt;
72 m_elapsed += dt;
73
73
74 if (m_elapsed > m_duration)
74 if (m_elapsed > m_duration)
75 m_elapsed = m_duration;
75 m_elapsed = m_duration;
76
76
77 try
77 try
78 {
78 {
79 var handler = Step;
79 var handler = Step;
80 if (handler != null)
80 if (handler != null)
81 handler(m_arg, m_elapsed, m_duration);
81 handler(m_arg, m_elapsed, m_duration);
82 }
82 }
83 catch (Exception e)
83 catch (Exception e)
84 {
84 {
85 Trace.TraceError(e.ToString());
85 Trace.TraceError(e.ToString());
86 }
86 }
87
87
88 if (m_elapsed < m_duration)
88 if (m_elapsed < m_duration)
89 timer.Start();
89 timer.Start();
90 else
90 else
91 {
91 {
92 timer.Dispose();
92 timer.Dispose();
93 m_promise.Resolve(m_arg);
93 m_promise.Resolve(m_arg);
94 }
94 }
95 }
95 }
96 }
96 }
97 }
97 }
Show file before | Show file after | Hide comments
1 NO CONTENT: modified file, binary diff hidden
NO CONTENT: modified file, binary diff hidden
Show file before | Show file after | Hide comments
@@ -1,355 +1,397
1 using System;
1 using System;
2 using System.Collections.Generic;
2 using System.Collections.Generic;
3 using System.Linq;
3 using System.Linq;
4 using System.Reflection;
4 using System.Reflection;
5 using System.Text;
5 using System.Text;
6 using System.Diagnostics;
6 using System.Diagnostics;
7 using System.Threading;
7 using System.Threading;
8
8
9 namespace Implab {
9 namespace Implab {
10
10
11 public delegate void ErrorHandler(Exception e);
11 public delegate void ErrorHandler(Exception e);
12
12
13 public delegate void ResultHandler<T>(T result);
13 public delegate void ResultHandler<T>(T result);
14 public delegate TNew ResultMapper<TSrc,TNew>(TSrc result);
14 public delegate TNew ResultMapper<TSrc, TNew>(TSrc result);
15 public delegate Promise<TNew> ChainedOperation<TSrc,TNew>(TSrc result);
15 public delegate Promise<TNew> ChainedOperation<TSrc, TNew>(TSrc result);
16
16
17 /// <summary>
17 /// <summary>
18 /// Класс для асинхронного получения результатов. Так называемое "обещание".
18 /// Класс для асинхронного получения результатов. Так называемое "обещание".
19 /// </summary>
19 /// </summary>
20 /// <typeparam name="T">Тип получаемого результата</typeparam>
20 /// <typeparam name="T">Тип получаемого результата</typeparam>
21 /// <remarks>
21 /// <remarks>
22 /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,
22 /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,
23 /// клиент получив такое обещание может установить ряд обратных вызово для получения
23 /// клиент получив такое обещание может установить ряд обратных вызово для получения
24 /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>
24 /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>
25 /// <para>
25 /// <para>
26 /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на
26 /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на
27 /// данные события клиент должен использовать методы <c>Then</c>.
27 /// данные события клиент должен использовать методы <c>Then</c>.
28 /// </para>
28 /// </para>
29 /// <para>
29 /// <para>
30 /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),
30 /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),
31 /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о
31 /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о
32 /// выполнении обещания.
32 /// выполнении обещания.
33 /// </para>
33 /// </para>
34 /// <para>
34 /// <para>
35 /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,
35 /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,
36 /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном
36 /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном
37 /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в
37 /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в
38 /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении
38 /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении
39 /// обещания.
39 /// обещания.
40 /// </para>
40 /// </para>
41 /// <para>
41 /// <para>
42 /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать
42 /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать
43 /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует
43 /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует
44 /// использовать соответствующую форму методе <c>Then</c>.
44 /// использовать соответствующую форму методе <c>Then</c>.
45 /// </para>
45 /// </para>
46 /// <para>
46 /// <para>
47 /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать
47 /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать
48 /// только инициатор обещания иначе могут возникнуть противоречия.
48 /// только инициатор обещания иначе могут возникнуть противоречия.
49 /// </para>
49 /// </para>
50 /// </remarks>
50 /// </remarks>
51 public class Promise<T> {
51 public class Promise<T> {
52
52
53 struct ResultHandlerInfo {
53 struct ResultHandlerInfo {
54 public ResultHandler<T> resultHandler;
54 public ResultHandler<T> resultHandler;
55 public ErrorHandler errorHandler;
55 public ErrorHandler errorHandler;
56 }
56 }
57
57
58 enum State {
58 enum State {
59 Unresolved,
59 Unresolved,
60 Resolving,
60 Resolving,
61 Resolved,
61 Resolved,
62 Cancelled
62 Cancelled
63 }
63 }
64
64
65 LinkedList<ResultHandlerInfo> m_handlersChain = new LinkedList<ResultHandlerInfo>();
65 LinkedList<ResultHandlerInfo> m_handlersChain = new LinkedList<ResultHandlerInfo>();
66 State m_state;
66 State m_state;
67 bool m_cancellable;
67 bool m_cancellable;
68 T m_result;
68 T m_result;
69 Exception m_error;
69 Exception m_error;
70
70
71 public Promise() {
71 public Promise() {
72 m_cancellable = true;
72 m_cancellable = true;
73 }
73 }
74
74
75 /// <summary>
75 /// <summary>
76 /// Событие, возникающее при отмене асинхронной операции.
76 /// Событие, возникающее при отмене асинхронной операции.
77 /// </summary>
77 /// </summary>
78 /// <description>
78 /// <description>
79 /// Как правило используется для оповещения объекта, выполняющего асинхронную операцию, о том, что ее следует отменить.
79 /// Как правило используется для оповещения объекта, выполняющего асинхронную операцию, о том, что ее следует отменить.
80 /// </description>
80 /// </description>
81 public event EventHandler Cancelled;
81 public event EventHandler Cancelled;
82
82
83 /// <summary>
83 /// <summary>
84 /// Выполняет обещание, сообщая об успешном выполнении.
84 /// Выполняет обещание, сообщая об успешном выполнении.
85 /// </summary>
85 /// </summary>
86 /// <param name="result">Результат выполнения.</param>
86 /// <param name="result">Результат выполнения.</param>
87 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
87 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
88 public void Resolve(T result) {
88 public void Resolve(T result) {
89 lock (this) {
89 lock (this) {
90 if (m_state == State.Cancelled)
90 if (m_state == State.Cancelled)
91 return;
91 return;
92 if (m_state != State.Unresolved)
92 if (m_state != State.Unresolved)
93 throw new InvalidOperationException("The promise is already resolved");
93 throw new InvalidOperationException("The promise is already resolved");
94 m_result = result;
94 m_result = result;
95 m_state = State.Resolving;
95 m_state = State.Resolving;
96 }
96 }
97
97
98 ResultHandlerInfo handler;
98 ResultHandlerInfo handler;
99 while (FetchNextHandler(out handler))
99 while (FetchNextHandler(out handler))
100 InvokeHandler(handler);
100 InvokeHandler(handler);
101 }
101 }
102
102
103 /// <summary>
103 /// <summary>
104 /// Выполняет обещание, сообщая об ошибке
104 /// Выполняет обещание, сообщая об ошибке
105 /// </summary>
105 /// </summary>
106 /// <param name="error">Исключение возникшее при выполнении операции</param>
106 /// <param name="error">Исключение возникшее при выполнении операции</param>
107 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
107 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
108 public void Reject(Exception error) {
108 public void Reject(Exception error) {
109 lock (this) {
109 lock (this) {
110 if (m_state == State.Cancelled)
110 if (m_state == State.Cancelled)
111 return;
111 return;
112 if (m_state != State.Unresolved)
112 if (m_state != State.Unresolved)
113 throw new InvalidOperationException("The promise is already resolved");
113 throw new InvalidOperationException("The promise is already resolved");
114 m_error = error;
114 m_error = error;
115 m_state = State.Resolving;
115 m_state = State.Resolving;
116 }
116 }
117
117
118 ResultHandlerInfo handler;
118 ResultHandlerInfo handler;
119 while (FetchNextHandler(out handler))
119 while (FetchNextHandler(out handler))
120 InvokeHandler(handler);
120 InvokeHandler(handler);
121 }
121 }
122
122
123 /// <summary>
123 /// <summary>
124 /// Отменяет операцию, если это возможно.
124 /// Отменяет операцию, если это возможно.
125 /// </summary>
125 /// </summary>
126 /// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
126 /// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
127 public bool Cancel() {
127 public bool Cancel() {
128 lock(this) {
128 lock (this) {
129 if (m_state == State.Unresolved && m_cancellable) {
129 if (m_state == State.Unresolved && m_cancellable) {
130 m_state = State.Cancelled;
130 m_state = State.Cancelled;
131 EventHandler temp = Cancelled;
131 EventHandler temp = Cancelled;
132
132
133 if (temp != null)
133 if (temp != null)
134 temp(this,new EventArgs());
134 temp(this, new EventArgs());
135
135
136 return true;
136 return true;
137 } else
137 } else
138 return false;
138 return false;
139 }
139 }
140 }
140 }
141
141
142 /// <summary>
142 /// <summary>
143 /// Добавляет обработчики событий выполнения обещания.
143 /// Добавляет обработчики событий выполнения обещания.
144 /// </summary>
144 /// </summary>
145 /// <param name="success">Обработчик успешного выполнения обещания.
145 /// <param name="success">Обработчик успешного выполнения обещания.
146 /// Данному обработчику будет передан результат выполнения операции.</param>
146 /// Данному обработчику будет передан результат выполнения операции.</param>
147 /// <param name="error">Обработчик ошибки. Данный обработчик получит
147 /// <param name="error">Обработчик ошибки. Данный обработчик получит
148 /// исключение возникшее при выполнении операции.</param>
148 /// исключение возникшее при выполнении операции.</param>
149 /// <returns>Само обещание</returns>
149 /// <returns>Само обещание</returns>
150 public Promise<T> Then(ResultHandler<T> success, ErrorHandler error) {
150 public Promise<T> Then(ResultHandler<T> success, ErrorHandler error) {
151 if (success == null && error == null)
151 if (success == null && error == null)
152 return this;
152 return this;
153
153
154 AddHandler(new ResultHandlerInfo() {
154 var medium = new Promise<T>();
155 resultHandler = success,
155
156 errorHandler = error
156 var handlerInfo = new ResultHandlerInfo();
157 });
158
157
159 return this;
158 if (success != null)
159 handlerInfo.resultHandler = x => {
160 try {
161 success(x);
162 medium.Resolve(x);
163 } catch (Exception e) {
164 medium.Reject(e);
165 }
166 };
167 else
168 handlerInfo.resultHandler = x => medium.Resolve(x);
169
170 if (error != null)
171 handlerInfo.errorHandler = x => {
172 try {
173 error(x);
174 } catch { }
175 medium.Reject(x);
176 };
177 else
178 handlerInfo.errorHandler = x => medium.Reject(x);
179
180 AddHandler(handlerInfo);
181
182 return medium;
160 }
183 }
161
184
162 public Promise<T> Then(ResultHandler<T> success) {
185 public Promise<T> Then(ResultHandler<T> success) {
163 return Then (success, null);
186 return Then(success, null);
164 }
187 }
165
188
189 public Promise<T> Error(ErrorHandler error) {
190 return Then(null, error);
191 }
192
166 public Promise<T> Anyway(Action handler) {
193 public Promise<T> Anyway(Action handler) {
167 if (handler == null)
194 if (handler == null)
168 return this;
195 return this;
196
197 var medium = new Promise<T>();
198
169 AddHandler(new ResultHandlerInfo {
199 AddHandler(new ResultHandlerInfo {
170 resultHandler = x => handler(),
200 resultHandler = x => {
171 errorHandler = x => handler()
201 try {
202 handler();
203 medium.Resolve(x);
204 } catch (Exception e) {
205 medium.Reject(e);
206 }
207 },
208 errorHandler = x => {
209 try {
210 handler();
211 } catch { }
212 medium.Reject(x);
213 }
172 });
214 });
173
215
174 return this;
216 return medium;
175 }
217 }
176
218
177 /// <summary>
219 /// <summary>
178 /// Позволяет преобразовать результат выполения операции к новому типу.
220 /// Позволяет преобразовать результат выполения операции к новому типу.
179 /// </summary>
221 /// </summary>
180 /// <typeparam name="TNew">Новый тип результата.</typeparam>
222 /// <typeparam name="TNew">Новый тип результата.</typeparam>
181 /// <param name="mapper">Преобразование результата к новому типу.</param>
223 /// <param name="mapper">Преобразование результата к новому типу.</param>
182 /// <param name="error">Обработчик ошибки. Данный обработчик получит
224 /// <param name="error">Обработчик ошибки. Данный обработчик получит
183 /// исключение возникшее при выполнении операции.</param>
225 /// исключение возникшее при выполнении операции.</param>
184 /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
226 /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
185 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler error) {
227 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler error) {
186 if (mapper == null)
228 if (mapper == null)
187 throw new ArgumentNullException("mapper");
229 throw new ArgumentNullException("mapper");
188
230
189 // создаем прицепленное обещание
231 // создаем прицепленное обещание
190 Promise<TNew> chained = new Promise<TNew>();
232 Promise<TNew> chained = new Promise<TNew>();
191
233
192 AddHandler(new ResultHandlerInfo() {
234 AddHandler(new ResultHandlerInfo() {
193 resultHandler = delegate(T result) {
235 resultHandler = delegate(T result) {
194 try {
236 try {
195 // если преобразование выдаст исключение, то сработает reject сцепленного deferred
237 // если преобразование выдаст исключение, то сработает reject сцепленного deferred
196 chained.Resolve(mapper(result));
238 chained.Resolve(mapper(result));
197 } catch (Exception e) {
239 } catch (Exception e) {
198 chained.Reject(e);
240 chained.Reject(e);
199 }
241 }
200 },
242 },
201 errorHandler = delegate(Exception e) {
243 errorHandler = delegate(Exception e) {
202 if (error != null)
244 if (error != null)
203 error(e);
245 error(e);
204 // в случае ошибки нужно передать исключение дальше по цепочке
246 // в случае ошибки нужно передать исключение дальше по цепочке
205 chained.Reject(e);
247 chained.Reject(e);
206 }
248 }
207 });
249 });
208
250
209 return chained;
251 return chained;
210 }
252 }
211
253
212 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
254 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
213 return Map (mapper, null);
255 return Map(mapper, null);
214 }
256 }
215
257
216 /// <summary>
258 /// <summary>
217 /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
259 /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
218 /// выполнения текущей, а результат текущей операции может быть использован для инициализации
260 /// выполнения текущей, а результат текущей операции может быть использован для инициализации
219 /// новой операции.
261 /// новой операции.
220 /// </summary>
262 /// </summary>
221 /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
263 /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
222 /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
264 /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
223 /// <param name="error">Обработчик ошибки. Данный обработчик получит
265 /// <param name="error">Обработчик ошибки. Данный обработчик получит
224 /// исключение возникшее при выполнении текуещй операции.</param>
266 /// исключение возникшее при выполнении текуещй операции.</param>
225 /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
267 /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
226 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler error) {
268 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler error) {
227
269
228 // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
270 // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
229 // создать посредника, к которому будут подвызяваться следующие обработчики.
271 // создать посредника, к которому будут подвызяваться следующие обработчики.
230 // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
272 // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
231 // передать через него результаты работы.
273 // передать через него результаты работы.
232 Promise<TNew> medium = new Promise<TNew>();
274 Promise<TNew> medium = new Promise<TNew>();
233
275
234 AddHandler(new ResultHandlerInfo() {
276 AddHandler(new ResultHandlerInfo() {
235 resultHandler = delegate(T result) {
277 resultHandler = delegate(T result) {
236 try {
278 try {
237 chained(result).Then(
279 chained(result).Then(
238 x => medium.Resolve(x),
280 x => medium.Resolve(x),
239 e => medium.Reject(e)
281 e => medium.Reject(e)
240 );
282 );
241 } catch(Exception e) {
283 } catch (Exception e) {
242 // если сцепленное действие выдало исключение вместо обещания, то передаем ошибку по цепочке
284 // если сцепленное действие выдало исключение вместо обещания, то передаем ошибку по цепочке
243 medium.Reject(e);
285 medium.Reject(e);
244 }
286 }
245 },
287 },
246 errorHandler = delegate(Exception e) {
288 errorHandler = delegate(Exception e) {
247 if (error != null)
289 if (error != null)
248 error(e);
290 error(e);
249 // в случае ошибки нужно передать исключение дальше по цепочке
291 // в случае ошибки нужно передать исключение дальше по цепочке
250 medium.Reject(e);
292 medium.Reject(e);
251 }
293 }
252 });
294 });
253
295
254 return medium;
296 return medium;
255 }
297 }
256
298
257 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
299 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
258 return Chain (chained, null);
300 return Chain(chained, null);
259 }
301 }
260
302
261 /// <summary>
303 /// <summary>
262 /// Дожидается отложенного обещания и в случае успеха, возвращает
304 /// Дожидается отложенного обещания и в случае успеха, возвращает
263 /// его, результат, в противном случае бросает исключение.
305 /// его, результат, в противном случае бросает исключение.
264 /// </summary>
306 /// </summary>
265 /// <remarks>
307 /// <remarks>
266 /// <para>
308 /// <para>
267 /// Если ожидание обещания было прервано по таймауту, это не значит,
309 /// Если ожидание обещания было прервано по таймауту, это не значит,
268 /// что обещание было отменено или что-то в этом роде, это только
310 /// что обещание было отменено или что-то в этом роде, это только
269 /// означает, что мы его не дождались, однако все зарегистрированные
311 /// означает, что мы его не дождались, однако все зарегистрированные
270 /// обработчики, как были так остались и они будут вызваны, когда
312 /// обработчики, как были так остались и они будут вызваны, когда
271 /// обещание будет выполнено.
313 /// обещание будет выполнено.
272 /// </para>
314 /// </para>
273 /// <para>
315 /// <para>
274 /// Такое поведение вполне оправдано поскольку таймаут может истечь
316 /// Такое поведение вполне оправдано поскольку таймаут может истечь
275 /// в тот момент, когда началась обработка цепочки обработчиков, и
317 /// в тот момент, когда началась обработка цепочки обработчиков, и
276 /// к тому же текущее обещание может стоять в цепочке обещаний и его
318 /// к тому же текущее обещание может стоять в цепочке обещаний и его
277 /// отклонение может привести к непрогнозируемому результату.
319 /// отклонение может привести к непрогнозируемому результату.
278 /// </para>
320 /// </para>
279 /// </remarks>
321 /// </remarks>
280 /// <param name="timeout">Время ожидания</param>
322 /// <param name="timeout">Время ожидания</param>
281 /// <returns>Результат выполнения обещания</returns>
323 /// <returns>Результат выполнения обещания</returns>
282 public T Join(int timeout) {
324 public T Join(int timeout) {
283 ManualResetEvent evt = new ManualResetEvent(false);
325 ManualResetEvent evt = new ManualResetEvent(false);
284 Anyway(() => evt.Set());
326 Anyway(() => evt.Set());
285
327
286 if (!evt.WaitOne(timeout, true))
328 if (!evt.WaitOne(timeout, true))
287 throw new TimeoutException();
329 throw new TimeoutException();
288
330
289 if (m_error != null)
331 if (m_error != null)
290 throw new TargetInvocationException( m_error );
332 throw new TargetInvocationException(m_error);
291 else
333 else
292 return m_result;
334 return m_result;
293 }
335 }
294
336
295 public T Join() {
337 public T Join() {
296 return Join(Timeout.Infinite);
338 return Join(Timeout.Infinite);
297 }
339 }
298
340
299 /// <summary>
341 /// <summary>
300 /// Данный метод последовательно извлекает обработчики обещания и когда
342 /// Данный метод последовательно извлекает обработчики обещания и когда
301 /// их больше не осталось - ставит состояние "разрешено".
343 /// их больше не осталось - ставит состояние "разрешено".
302 /// </summary>
344 /// </summary>
303 /// <param name="handler">Информация об обработчике</param>
345 /// <param name="handler">Информация об обработчике</param>
304 /// <returns>Признак того, что еще остались обработчики в очереди</returns>
346 /// <returns>Признак того, что еще остались обработчики в очереди</returns>
305 bool FetchNextHandler(out ResultHandlerInfo handler) {
347 bool FetchNextHandler(out ResultHandlerInfo handler) {
306 handler = default(ResultHandlerInfo);
348 handler = default(ResultHandlerInfo);
307
349
308 lock (this) {
350 lock (this) {
309 Debug.Assert(m_state == State.Resolving);
351 Debug.Assert(m_state == State.Resolving);
310
352
311 if (m_handlersChain.Count > 0) {
353 if (m_handlersChain.Count > 0) {
312 handler = m_handlersChain.First.Value;
354 handler = m_handlersChain.First.Value;
313 m_handlersChain.RemoveFirst();
355 m_handlersChain.RemoveFirst();
314 return true;
356 return true;
315 } else {
357 } else {
316 m_state = State.Resolved;
358 m_state = State.Resolved;
317 return false;
359 return false;
318 }
360 }
319 }
361 }
320 }
362 }
321
363
322 void AddHandler(ResultHandlerInfo handler) {
364 void AddHandler(ResultHandlerInfo handler) {
323 bool invokeRequired = false;
365 bool invokeRequired = false;
324
366
325 lock (this) {
367 lock (this) {
326 if (m_state != State.Resolved)
368 if (m_state != State.Resolved)
327 m_handlersChain.AddLast(handler);
369 m_handlersChain.AddLast(handler);
328 else
370 else
329 invokeRequired = true;
371 invokeRequired = true;
330 }
372 }
331
373
332 // обработчики не должны блокировать сам объект
374 // обработчики не должны блокировать сам объект
333 if (invokeRequired)
375 if (invokeRequired)
334 InvokeHandler(handler);
376 InvokeHandler(handler);
335 }
377 }
336
378
337 void InvokeHandler(ResultHandlerInfo handler) {
379 void InvokeHandler(ResultHandlerInfo handler) {
338 if (m_error == null) {
380 if (m_error == null) {
339 try {
381 try {
340 if (handler.resultHandler != null)
382 if (handler.resultHandler != null)
341 handler.resultHandler(m_result);
383 handler.resultHandler(m_result);
342 } catch { }
384 } catch { }
343 }
385 }
344
386
345 if (m_error != null) {
387 if (m_error != null) {
346 try {
388 try {
347 if (handler.errorHandler !=null)
389 if (handler.errorHandler != null)
348 handler.errorHandler(m_error);
390 handler.errorHandler(m_error);
349 } catch { }
391 } catch { }
350 }
392 }
351 }
393 }
352
394
353
395
354 }
396 }
355 }
397 }
General Comments 0
You need to be logged in to leave comments. Login now