implab/ImplabNet Commit - r89:ce0171cacec4

improved performance of a chained map operation

cin -

r89:ce0171cacec4 v2

parent child

Context file:

r89:ce0171cacec4

Collapse all files

Implab/Parallels/ArrayTraits.cs +9 -7

                                      break; // stop processing in case of error or cancellation
                                  var idx = i;
-                                 lock(locker) {
-                                     while(slots == 0)
-                                         Monitor.Wait(locker);
-                                     slots--;
+                                 if (Interlocked.Decrement(ref slots) < 0) {
+                                     lock(locker) {
+                                         while(slots < 0)
+                                             Monitor.Wait(locker);
+                                     }
                                  }
                                  try {
                                      transform(source[i])
                                          .Anyway(() => {
-                                             lock(locker) {
-                                                 slots ++;
+                                             Interlocked.Increment(ref slots);
+                                             lock (locker) {
                                                  Monitor.Pulse(locker);
                                              }
                                          })
                                                  if (left == 0)
                                                      promise.Resolve(res);
                                              },
-                                             e => promise.Reject(e)
+                                             promise.Reject
                                          );
                                  } catch (Exception e) {

Implab/Parallels/DispatchPool.cs +1 -1

                      protected abstract bool TryDequeue(out TUnit unit);
-                     private bool Dequeue(out TUnit unit, int timeout) {
+                     bool Dequeue(out TUnit unit, int timeout) {
                          int ts = Environment.TickCount;
                          if (TryDequeue(out unit))
                              return true;

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