Mercurial > pub > ImplabNet
comparison Implab/Parallels/AsyncPool.cs @ 121:62d2f1e98c4e v2
working version of AsyncQueue and batch operations
tests
| author | cin |
|---|---|
| date | Mon, 12 Jan 2015 18:19:41 +0300 |
| parents | f1b897999260 |
| children | a336cb13c6a9 |
comparison
equal
deleted
inserted
replaced
| 120:f1b897999260 | 121:62d2f1e98c4e |
|---|---|
| 73 worker.Start(); | 73 worker.Start(); |
| 74 | 74 |
| 75 return p; | 75 return p; |
| 76 } | 76 } |
| 77 | 77 |
| 78 public static IPromise[] ThreadRun(params Action[] func) { | 78 public static IPromise[] RunThread(params Action[] func) { |
| 79 return func.Select(f => InvokeNewThread(f)).ToArray(); | 79 return func.Select(f => InvokeNewThread(f)).ToArray(); |
| 80 } | 80 } |
| 81 | 81 |
| 82 public static IPromise<T>[] ThreadRun<T>(params Func<T>[] func) { | 82 public static IPromise<T>[] RunThread<T>(params Func<T>[] func) { |
| 83 return func.Select(f => InvokeNewThread(f)).ToArray(); | 83 return func.Select(f => InvokeNewThread(f)).ToArray(); |
| 84 } | 84 } |
| 85 } | 85 } |
| 86 } | 86 } |
