implab/ImplabNet Commit - r33:b255e4aeef17

removed the reference to the parent from the promise object this allows...

cin -

r33:b255e4aeef17 default

parent child

Context file:

r33:b255e4aeef17

Collapse all files

Implab.Test/AsyncTests.cs +53 0

@@ -328,6 +328,59 namespace Implab.Test {
328	Assert.IsTrue(flags[1]);	328	Assert.IsTrue(flags[1]);
329	Assert.IsTrue(flags[2]);	329	Assert.IsTrue(flags[2]);
330	}	330	}
		331
		332	[TestMethod]
		333	public void ChainedCancel1Test() {
		334	// при отмене сцепленной асинхронной операции все обещание должно
		335	// завершаться ошибкой OperationCanceledException
		336	var p = PromiseHelper
		337	.Sleep(1, "Hi, HAL!")
		338	.Chain(x => {
		339	// запускаем две асинхронные операции
		340	var result = PromiseHelper.Sleep(1000, "HEM ENABLED!!!");
		341	// вторая операция отменяет первую до завершения
		342	PromiseHelper
		343	.Sleep(100, "HAL, STOP!")
		344	.Then(() => result.Cancel());
		345	return result;
		346	});
		347	try {
		348	p.Join();
		349	} catch (TargetInvocationException err) {
		350	Assert.IsTrue(err.InnerException is OperationCanceledException);
		351	}
		352	}
		353
		354	[TestMethod]
		355	public void ChainedCancel2Test() {
		356	// при отмене цепочки обещаний, вложенные операции также должны отменяться
		357	IPromiseBase p = null;
		358	var pSurvive = new Promise<bool>();
		359	var hemStarted = new ManualResetEvent(false);
		360	p = PromiseHelper
		361	.Sleep(1, "Hi, HAL!")
		362	.Chain(x => {
		363	hemStarted.Set();
		364	// запускаем две асинхронные операции
		365	var result = PromiseHelper
		366	.Sleep(1000, "HEM ENABLED!!!")
		367	.Then(s => pSurvive.Resolve(false));
		368
		369	result
		370	.Cancelled(() => pSurvive.Resolve(true));
		371
		372	return result;
		373	});
		374
		375	hemStarted.WaitOne();
		376	p.Cancel();
		377
		378	try {
		379	p.Join();
		380	} catch (OperationCanceledException) {
		381	Assert.IsTrue(pSurvive.Join());
		382	}
		383	}
331	}	384	}
332	}	385	}
333		386

Implab.suo binary modified 0 0

NO CONTENT: modified file, binary diff hidden

Implab/IPromise.cs +6 -7

                 public interface IPromise<T>: IPromiseBase
                 {
-                    T Join();
+                    new T Join();
+                    new T Join(int timeout);
-                    T Join(int timeout);
                     IPromise<T> Then(ResultHandler<T> success, ErrorHandler error);
                     IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error);
                     IPromise<T> Then(ResultHandler<T> success);
-                    IPromise<T> Error(ErrorHandler error);
+                    new IPromise<T> Error(ErrorHandler error);
                     IPromise<T> Error(ErrorHandler<T> error);
                     IPromise<T2> Map<T2>(ResultMapper<T,T2> mapper, ErrorHandler error);
                     IPromise<T2> Chain<T2>(ChainedOperation<T, T2> chained, ErrorHandler error);
                     IPromise<T2> Chain<T2>(ChainedOperation<T, T2> chained);
-                    IPromise<T> Cancelled(Action handler);
+                    new IPromise<T> Cancelled(Action handler);
-                    IPromise<T> Finally(Action handler);
+                    new IPromise<T> Finally(Action handler);
-                    IPromise<T> Anyway(Action handler);
+                    new IPromise<T> Anyway(Action handler);
                 }
             }

Implab/IPromiseBase.cs +7 0

                     IPromiseBase Then(Action success,ErrorHandler error);
                     IPromiseBase Then(Action success);
+                    IPromiseBase Error(ErrorHandler error);
+                    IPromiseBase Anyway(Action handler);
+                    IPromiseBase Finally(Action handler);
+                    IPromiseBase Cancelled(Action handler);
                     IPromise<T> Cast<T>();
+                    void Join();
+                    void Join(int timeout);
                 }
             }

Implab/Promise.cs +136 -43

@@ -11,7 +11,7 namespace Implab {
11	public delegate T ErrorHandler<out T>(Exception e);	11	public delegate T ErrorHandler<out T>(Exception e);
12	public delegate void ResultHandler<in T>(T result);	12	public delegate void ResultHandler<in T>(T result);
13	public delegate TNew ResultMapper<in TSrc, out TNew>(TSrc result);	13	public delegate TNew ResultMapper<in TSrc, out TNew>(TSrc result);
14	public delegate IPromise<TNew> ChainedOperation<in TSrc,TNew>(TSrc result);	14	public delegate IPromise<TNew> ChainedOperation<in TSrc, TNew>(TSrc result);
15		15
16	/// <summary>	16	/// <summary>
17	/// Класс для асинхронного получения результатов. Так называемое "обещание".	17	/// Класс для асинхронного получения результатов. Так называемое "обещание".
@@ -86,7 +86,6 namespace Implab {
86	const int RejectedState = 3;	86	const int RejectedState = 3;
87	const int CancelledState = 4;	87	const int CancelledState = 4;
88		88
89	readonly IPromiseBase m_parent;
90	readonly bool m_cancellable;	89	readonly bool m_cancellable;
91		90
92	int m_childrenCount = 0;	91	int m_childrenCount = 0;
@@ -102,12 +101,15 namespace Implab {
102		101
103	public Promise(IPromiseBase parent, bool cancellable) {	102	public Promise(IPromiseBase parent, bool cancellable) {
104	m_cancellable = cancellable;	103	m_cancellable = cancellable;
105	~~m_parent~~ = ~~parent~~;	104	if (parent != null)
106	}	105	AddHandler(
107		106	null,
108	void InternalCancel() {	107	null,
109	// don't try to cancel parent :)	108	() => {
110	Cancel(false);	109	if (parent.IsExclusive)
		110	parent.Cancel();
		111	}
		112	);
111	}	113	}
112		114
113	bool BeginTransit() {	115	bool BeginTransit() {
@@ -159,6 +161,16 namespace Implab {
159	}	161	}
160		162
161	/// <summary>	163	/// <summary>
		164	/// Выполняет обещание, сообщая об успешном выполнении. Результатом выполнения будет пустое значения.
		165	/// </summary>
		166	/// <remarks>
		167	/// Данный вариант удобен в случаях, когда интересен факт выполнения операции, нежели полученное значение.
		168	/// </remarks>
		169	public void Resolve() {
		170	Resolve(default(T));
		171	}
		172
		173	/// <summary>
162	/// Выполняет обещание, сообщая об ошибке	174	/// Выполняет обещание, сообщая об ошибке
163	/// </summary>	175	/// </summary>
164	/// <remarks>	176	/// <remarks>
@@ -185,7 +197,18 namespace Implab {
185	/// </summary>	197	/// </summary>
186	/// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>	198	/// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
187	public bool Cancel() {	199	public bool Cancel() {
188	return Cancel(true);	200	if (BeginTransit()) {
		201	CompleteTransit(CancelledState);
		202	OnStateChanged();
		203	return true;
		204	} else {
		205	return false;
		206	}
		207	}
		208
		209	// сделано для возвращаемого типа void
		210	protected void InternalCancel() {
		211	Cancel();
189	}	212	}
190		213
191	/// <summary>	214	/// <summary>
@@ -229,13 +252,11 namespace Implab {
229	return medium;	252	return medium;
230	}	253	}
231		254
232	public IPromiseBase Then(Action success,ErrorHandler error)	255	public IPromiseBase Then(Action success, ErrorHandler error) {
233	{
234	return Then(x => success(), error);	256	return Then(x => success(), error);
235	}	257	}
236		258
237	public IPromiseBase Then(Action success)	259	public IPromiseBase Then(Action success) {
238	{
239	return Then(x => success());	260	return Then(x => success());
240	}	261	}
241		262
@@ -267,7 +288,7 namespace Implab {
267	errorHandler = x => {	288	errorHandler = x => {
268	try {	289	try {
269	medium.Resolve(error(x));	290	medium.Resolve(error(x));
270	} catch(Exception e) {	291	} catch (Exception e) {
271	medium.Reject(e);	292	medium.Reject(e);
272	}	293	}
273	};	294	};
@@ -338,7 +359,7 namespace Implab {
338	if (handler == null)	359	if (handler == null)
339	return this;	360	return this;
340		361
341	var medium = new Promise<T>();	362	var medium = new Promise<T>(this,true);
342		363
343	AddHandler(	364	AddHandler(
344	x => {	365	x => {
@@ -377,7 +398,7 namespace Implab {
377	throw new ArgumentNullException("mapper");	398	throw new ArgumentNullException("mapper");
378		399
379	// создаем прицепленное обещание	400	// создаем прицепленное обещание
380	var chained = new Promise<TNew>();	401	var chained = new Promise<TNew>(this,true);
381		402
382	ResultHandler<T> resultHandler = result => chained.Resolve(mapper(result));	403	ResultHandler<T> resultHandler = result => chained.Resolve(mapper(result));
383	ErrorHandler errorHandler = delegate(Exception e) {	404	ErrorHandler errorHandler = delegate(Exception e) {
@@ -427,12 +448,21 namespace Implab {
427		448
428	var promise = chained(result);	449	var promise = chained(result);
429		450
430	// notify chained operation that it's not needed
431	medium.Cancelled(() => promise.Cancel());
432	promise.Then(	451	promise.Then(
433	x => medium.Resolve(x),	452	x => medium.Resolve(x),
434	e => medium.Reject(e)	453	e => medium.Reject(e)
435	);	454	);
		455
		456	// notify chained operation that it's not needed anymore
		457	// порядок вызова Then, Cancelled важен, поскольку от этого
		458	// зависит IsExclusive
		459	medium.Cancelled(() => {
		460	if(promise.IsExclusive)
		461	promise.Cancel();
		462	});
		463
		464	// внешняя отмена связанной операции рассматривается как ошибка
		465	promise.Cancelled(() => medium.Reject(new OperationCanceledException()));
436	};	466	};
437		467
438	ErrorHandler errorHandler = delegate(Exception e) {	468	ErrorHandler errorHandler = delegate(Exception e) {
@@ -531,7 +561,8 namespace Implab {
531	}	561	}
532		562
533	void AddHandler(ResultHandler<T> success, ErrorHandler error, Action cancel) {	563	void AddHandler(ResultHandler<T> success, ErrorHandler error, Action cancel) {
534	Interlocked.Increment(ref m_childrenCount);	564	if (success != null \|\| error != null)
		565	Interlocked.Increment(ref m_childrenCount);
535		566
536	HandlerDescriptor handler = new HandlerDescriptor {	567	HandlerDescriptor handler = new HandlerDescriptor {
537	resultHandler = success,	568	resultHandler = success,
@@ -588,20 +619,6 namespace Implab {
588	}	619	}
589	}	620	}
590		621
591	protected bool Cancel(bool dependencies) {
592	if (BeginTransit()) {
593	CompleteTransit(CancelledState);
594	OnStateChanged();
595
596	if (dependencies && m_parent != null && m_parent.IsExclusive)
597	m_parent.Cancel();
598
599	return true;
600	} else {
601	return false;
602	}
603	}
604
605	/// <summary>	622	/// <summary>
606	/// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний.	623	/// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний.
607	/// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено.	624	/// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено.
@@ -629,20 +646,25 namespace Implab {
629	for (int i = 0; i < promises.Count; i++) {	646	for (int i = 0; i < promises.Count; i++) {
630	var dest = i;	647	var dest = i;
631		648
632	promises[i].~~Then~~(	649	if (promises[i] != null) {
633	x => {	650	promises[i].Then(
634	~~result~~[~~dest~~] = x;	651	x => {
635	if(Interlocked.Decrement(ref pending) == 0)	652	result[dest] = x;
636	promise.Resolve(result);	653	if (Interlocked.Decrement(ref pending) == 0)
637	},	654	promise.Resolve(result);
638	e => ~~promise~~.~~Reject~~(e)	655	},
639	);	656	e => promise.Reject(e)
		657	);
		658	} else {
		659	if (Interlocked.Decrement(ref pending) == 0)
		660	promise.Resolve(result);
		661	}
640	}	662	}
641		663
642	promise.Cancelled(	664	promise.Cancelled(
643	() => {	665	() => {
644	foreach(var d in promises)	666	foreach (var d in promises)
645	if(d.IsExclusive)	667	if (d != null && d.IsExclusive)
646	d.Cancel();	668	d.Cancel();
647	}	669	}
648	);	670	);
@@ -650,6 +672,47 namespace Implab {
650	return promise;	672	return promise;
651	}	673	}
652		674
		675	/// <summary>
		676	/// Объединяет несколько обещаний в одно. Результирующее обещание будет выполнено при
		677	/// выполнении всех указанных обещаний. При этом возвращаемые значения первичных обещаний
		678	/// игнорируются.
		679	/// </summary>
		680	/// <param name="promises">Коллекция первичных обещаний, которые будут объеденены в одно.</param>
		681	/// <returns>Новое обещание, объединяющее в себе переданные.</returns>
		682	/// <remarks>
		683	/// Если в коллекции встречаюься <c>null</c>, то они воспринимаются как выполненные обещания.
		684	/// </remarks>
		685	public static IPromiseBase CreateComposite(ICollection<IPromiseBase> promises) {
		686	if (promises == null)
		687	throw new ArgumentNullException();
		688	if (promises.Count == 0)
		689	return Promise<object>.ResultToPromise(null);
		690
		691	int countdown = promises.Count;
		692
		693	var result = new Promise<object>();
		694
		695	foreach (var d in promises) {
		696	if (d == null) {
		697	if (Interlocked.Decrement(ref countdown) == 0)
		698	result.Resolve(null);
		699	} else {
		700	d.Then(() => {
		701	if (Interlocked.Decrement(ref countdown) == 0)
		702	result.Resolve(null);
		703	});
		704	}
		705	}
		706
		707	result.Cancelled(() => {
		708	foreach (var d in promises)
		709	if (d != null && d.IsExclusive)
		710	d.Cancel();
		711	});
		712
		713	return result;
		714	}
		715
653	public static Promise<T> ResultToPromise(T result) {	716	public static Promise<T> ResultToPromise(T result) {
654	var p = new Promise<T>();	717	var p = new Promise<T>();
655	p.Resolve(result);	718	p.Resolve(result);
@@ -665,5 +728,35 namespace Implab {
665	return p;	728	return p;
666	}	729	}
667		730
		731	#region IPromiseBase explicit implementation
		732
		733	IPromiseBase IPromiseBase.Error(ErrorHandler error) {
		734	return Error(error);
		735	}
		736
		737	IPromiseBase IPromiseBase.Anyway(Action handler) {
		738	return Anyway(handler);
		739	}
		740
		741	IPromiseBase IPromiseBase.Finally(Action handler) {
		742	return Finally(handler);
		743	}
		744
		745	IPromiseBase IPromiseBase.Cancelled(Action handler) {
		746	return Cancelled(handler);
		747	}
		748
		749	void IPromiseBase.Join() {
		750	Join();
		751	}
		752
		753	void IPromiseBase.Join(int timeout) {
		754	Join(timeout);
		755	}
		756
		757	#endregion
		758
		759
		760
668	}	761	}
669	}	762	}

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages