Mercurial > pub > ImplabNet

diff Implab/Parallels/ArrayTraits.cs @ 124:a336cb13c6a9 v2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
major update, added Drain mathod to AsyncQueue class
author cin
date Thu, 15 Jan 2015 02:43:14 +0300
parents 2573b562e328
children 706fccb85524
line wrap: on
line diff
--- a/Implab/Parallels/ArrayTraits.cs	Tue Jan 13 01:42:38 2015 +0300
+++ b/Implab/Parallels/ArrayTraits.cs	Thu Jan 15 02:43:14 2015 +0300
@@ -162,7 +162,7 @@
             int slots = threads;
 
             // Analysis disable AccessToDisposedClosure
-            AsyncPool.InvokeNewThread<int>(() => {
+            AsyncPool.RunThread<int>(() => {
                 for (int i = 0; i < source.Length; i++) {
                     if(promise.IsResolved)
                         break; // stop processing in case of error or cancellation