implab/ImplabNet Commit - r30:2fad2d1f4b03

small refactoring, cleanup.

cin -

r30:2fad2d1f4b03 default

parent child

Context file:

r30:2fad2d1f4b03

Collapse all files

Implab.Fx/AnimationHelpers.cs +2 -2

                         return anim;
                     }
-                    public static Promise<T> CloseFadeOut<T>(this T ctl) where T : Form
+                    public static IPromise<T> CloseFadeOut<T>(this T ctl) where T : Form
                     {
                         var anim = ctl.AnimateTransparency(0);
                         return anim.Play().DispatchToControl(ctl).Then(frm => frm.Close());
                     }
-                    public static Promise<T> OverlayFadeIn<T>(this Form that, T overlay) where T : Form
+                    public static IPromise<T> OverlayFadeIn<T>(this Form that, T overlay) where T : Form
                     {
                         if (that == null)
                             throw new ArgumentNullException("that");

Implab.Test/AsyncTests.cs +1 -1

                             var t = Environment.TickCount;
                             var res = args
-                                .ChainedMap2(
+                                .ChainedMap(
                                     x => pool.Invoke(
                                         () => Math.Sin(x * x)
                                     ),

Implab/Parallels/ArrayTraits.cs +3 -2

                         }
                     }
-                    public static Promise<TDst[]> ParallelMap<TSrc, TDst> (this TSrc[] source, Func<TSrc,TDst> transform, int threads) {
+                    public static IPromise<TDst[]> ParallelMap<TSrc, TDst> (this TSrc[] source, Func<TSrc,TDst> transform, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (transform == null)
                         return mapper.Promise;
                     }
-                    public static Promise<int> ParallelForEach<TSrc>(this TSrc[] source, Action<TSrc> action, int threads) {
+                    public static IPromise<int> ParallelForEach<TSrc>(this TSrc[] source, Action<TSrc> action, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (action == null)
                         var promise = new Promise<TDst[]>();
                         var res = new TDst[source.Length];
                         var pending = source.Length;
                         var semaphore = new Semaphore(threads, threads);
                         AsyncPool.InvokeNewThread(() => {

Implab/Parallels/DispatchPool.cs +16 -13

@@ -143,19 +143,25 namespace Implab.Parallels {
143	// anyway it may take some time for the thread to start	143	// anyway it may take some time for the thread to start
144	// we will ensure that at least one thread is running	144	// we will ensure that at least one thread is running
145		145
		146	EnsurePoolIsAlive();
		147	} else {
		148	// if there is no sleeping threads in the pool
		149	if (!StartWorker()) {
		150	// we haven't started a new thread, but the current can be on the way to terminate and it can't process the queue
		151	// send it a signal to spin again
		152	SignalThread();
		153	EnsurePoolIsAlive();
		154	}
		155	}
		156	}
		157
		158	private void EnsurePoolIsAlive() {
146	if (AllocateThreadSlot(1)) {	159	if (AllocateThreadSlot(1)) {
147	// if there were no threads in the pool	160	// if there were no threads in the pool
148	var worker = new Thread(this.Worker);	161	var worker = new Thread(this.Worker);
149	worker.IsBackground = true;	162	worker.IsBackground = true;
150	worker.Start();	163	worker.Start();
151	}	164	}
152	} else {
153	// if there is no sleeping threads in the pool
154	if (!StartWorker())
155	// we haven't started a new thread, but the current can be on the way and it can't process the queue
156	// send it a signal to spin again
157	SignalThread();
158	}
159	}	165	}
160		166
161	private bool Suspend() {	167	private bool Suspend() {
@@ -177,12 +183,9 namespace Implab.Parallels {
177	// in case at the moment the last thread was being released	183	// in case at the moment the last thread was being released
178	// a new task was added to the queue, we need to try	184	// a new task was added to the queue, we need to try
179	// to revoke the thread to avoid the situation when the task is left unprocessed	185	// to revoke the thread to avoid the situation when the task is left unprocessed
180	if (last && ~~Sleep~~(0)) { // ~~Sleep~~(0) will fetch pending task or will return false	186	if (last && FetchSignalOrWait(0)) { // FetchSignalOrWait(0) will fetch pending task or will return false
181	if (AllocateThreadSlot(1))	187	SignalThread(); // since FetchSignalOrWait(0) has fetched the signal we need to reschedule it
182	return true; // spin again...	188	return AllocateThreadSlot(1); // ensure that at least one thread is alive
183	else
184	SignalThread(); // since Sleep(0) has fetched the signal we neet to reschedule it
185
186	}	189	}
187		190
188	return false;	191	return false;

Implab/Promise.cs +2 -2

                 public delegate T ErrorHandler<out T>(Exception e);
                 public delegate void ResultHandler<in T>(T result);
                 public delegate TNew ResultMapper<in TSrc, out TNew>(TSrc result);
-                public delegate Promise<TNew> ChainedOperation<in TSrc,TNew>(TSrc result);
+                public delegate IPromise<TNew> ChainedOperation<in TSrc,TNew>(TSrc result);
                 /// <summary>
                 /// Класс для асинхронного получения результатов. Так называемое "обещание".
                     /// <param name="promises">Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным.</param>
                     /// <returns>Обещание объединяющее в себе результат переданных обещаний.</returns>
                     /// <exception cref="ArgumentNullException"><paramref name="promises"/> не может быть null</exception>
-                    public static Promise<T[]> CreateComposite(IList<Promise<T>> promises) {
+                    public static IPromise<T[]> CreateComposite(IList<IPromise<T>> promises) {
                         if (promises == null)
                             throw new ArgumentNullException();

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