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 +18 -15

                              // anyway it may take some time for the thread to start
                              // we will ensure that at least one thread is running
-                             if (AllocateThreadSlot(1)) {
-                                 // if there were no threads in the pool
-                                 var worker = new Thread(this.Worker);
-                                 worker.IsBackground = true;
-                                 worker.Start();
+                             }
+                             EnsurePoolIsAlive();
                          } else {
                              // if there is no sleeping threads in the pool
-                             if (!StartWorker())
-                                 // we haven't started a new thread, but the current can be on the way and it can't process the queue
+                             if (!StartWorker()) {
+                                 // we haven't started a new thread, but the current can be on the way to terminate and it can't process the queue
                                  // send it a signal to spin again
-                                 SignalThread();
+                                 SignalThread();
+                                 EnsurePoolIsAlive();
+                             }
+                         }
+                     }
+                     private void EnsurePoolIsAlive() {
+                         if (AllocateThreadSlot(1)) {
+                             // if there were no threads in the pool
+                             var worker = new Thread(this.Worker);
+                             worker.IsBackground = true;
+                             worker.Start();
                          }
                      }
                              // in case at the moment the last thread was being released
                              // a new task was added to the queue, we need to try
                              // to revoke the thread to avoid the situation when the task is left unprocessed
-                             if (last && Sleep(0)) { // Sleep(0) will fetch pending task or will return false
-                                 if (AllocateThreadSlot(1))
-                                     return true; // spin again...
-                                 else
-                                     SignalThread(); // since Sleep(0) has fetched the signal we neet to reschedule it
+                             if (last && FetchSignalOrWait(0)) { // FetchSignalOrWait(0) will fetch pending task or will return false
+                                 SignalThread(); // since FetchSignalOrWait(0) has fetched the signal we need to reschedule it
+                                 return AllocateThreadSlot(1); // ensure that at least one thread is alive
                              }
                              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