implab/ImplabNet Files · Implab/AsyncPool.cs

inital progress handling

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

File last commit:

r0:279591fb4df3 default


                r7:7ea9363fef6c

promises

Download file

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

        user@factory.site.local
    
initial commit...

              r0
            
      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

user@factory.site.local initial commit...	r0	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;
		}
		}
		}