implab/ImplabNet Files · Implab/Parallels/AsyncPool.cs

Рефакторинг, журналирование

cin - - Load All Authors

File last commit:

r40:fe33f4e02ad5 default


                r44:e5ec543feee3

default

Download file

             AsyncPool.cs
        
                    50 lines
            
             | 1.4 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / Parallels / AsyncPool.cs
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      using Implab.Diagnostics;

      using System;

      using System.Threading;

      namespace Implab.Parallels {

      	/// <summary>

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

      	/// </summary>

      	/// <remarks>

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

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

      	/// </remarks>

      	public static class AsyncPool {

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

      			var p = new Promise<T>();

                  var caller = TraceContext.Snapshot();

      			ThreadPool.QueueUserWorkItem(param => {

                      TraceContext.Transfer(caller);

      				try {

      					p.Resolve(func());

      				} catch(Exception e) {

      					p.Reject(e);

      				}

      			});

      			return p;

      		}

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

                  var p = new Promise<T>();

                  var caller = TraceContext.Snapshot();

                  var worker = new Thread(() => {

                      TraceContext.Transfer(caller);

                      try {

                          p.Resolve(func());

                      } catch (Exception e) {

                          p.Reject(e);

                      }

                  });

                  worker.IsBackground = true;

                  worker.Start();

                  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 Implab.Diagnostics;
				using System;
				using System.Threading;

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

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

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

				return p;
				}

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

				var caller = TraceContext.Snapshot();

				var worker = new Thread(() => {
				TraceContext.Transfer(caller);
				try {
				p.Resolve(func());
				} catch (Exception e) {
				p.Reject(e);
				}
				});
				worker.IsBackground = true;
				worker.Start();

				return p;
				}
				}
				}