implab/ImplabNet Files · Implab/AsyncPool.cs

initial commit...

initial commit promises async model

user@factory.site.local - - Load All Authors

File last commit:

r0:279591fb4df3 default


                r0:279591fb4df3

default

Download file

             AsyncPool.cs
        
                    28 lines
            
             | 691 B
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / AsyncPool.cs
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      using System;

      using System.Threading;

      namespace Implab {

      	/// <summary>

      	/// Класс для распаралеливания задач.

      	/// </summary>

      	/// <remarks>

      	/// Используя данный класс и лямда выражения можно распараллелить

      	/// вычисления, для этого используется концепция обещаний.

      	/// </remarks>

      	public static class AsyncPool {

      		public static Promise<T> Invoke<T>(Func<T> func) {

      			var p = new Promise<T>();

      			ThreadPool.QueueUserWorkItem(param => {

      				try {

      					p.Resolve(func());

      				} catch(Exception e) {

      					p.Reject(e);

      				}

      			});

      			return p;

      		}

      	}

      }

	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

				using System;
				using System.Threading;

				namespace Implab {
				/// <summary>
				/// Класс для распаралеливания задач.
				/// </summary>
				/// <remarks>
				/// Используя данный класс и лямда выражения можно распараллелить
				/// вычисления, для этого используется концепция обещаний.
				/// </remarks>
				public static class AsyncPool {

				public static Promise<T> Invoke<T>(Func<T> func) {
				var p = new Promise<T>();

				ThreadPool.QueueUserWorkItem(param => {
				try {
				p.Resolve(func());
				} catch(Exception e) {
				p.Reject(e);
				}
				});

				return p;
				}
				}
				}