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

Added 'Fail' method to RunnableComponent which allows component to move from...

Added 'Fail' method to RunnableComponent which allows component to move from Running to Failed state. Added PollingComponent a timer based runnable component More tests Added FailPromise a thin class to wrap exceptions Fixed error handling in SuccessPromise classes.

cin - - Load All Authors

File last commit:

r145:706fccb85524 v2


                r203:4d9830a9bbb8

Download file

             AsyncPool.cs
        
                    155 lines
            
             | 4.8 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / Parallels / AsyncPool.cs
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
initial log capabilities

              r35
            
      using Implab.Diagnostics;

        cin
    
refactoring

              r25
            
      using System;

      using System.Threading;

        cin
    
improved asyncpool usability...

              r120
            
      using System.Linq;

        cin
    
refactoring

              r25
            
      namespace Implab.Parallels {

      	/// <summary>

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

      	/// </summary>

      	/// <remarks>

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

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

      	/// </remarks>

      	public static class AsyncPool {

        cin
    
initial work on interactive logger

              r45
            
      		public static IPromise<T> Invoke<T>(Func<T> func) {

        cin
    
refactoring

              r25
            
      			var p = new Promise<T>();

        cin
    
rewritten tracing

              r92
            
                  var caller = TraceContext.Instance.CurrentOperation;

        cin
    
refactoring

              r25
            
      			ThreadPool.QueueUserWorkItem(param => {

        cin
    
rewritten tracing

              r92
            
                      TraceContext.Instance.EnterLogicalOperation(caller,false);

        cin
    
refactoring

              r25
            
      				try {

        cin
    
Implemented interllocked queue...

              r14
            
      					p.Resolve(func());

        cin
    
refactoring

              r25
            
      				} catch(Exception e) {

      					p.Reject(e);

        cin
    
rewritten tracing

              r92
            
                      } finally {

                          TraceContext.Instance.Leave();

                      }

        cin
    
refactoring

              r25
            
      			});

      			return p;

        cin
    
Implemented interllocked queue...

              r14
            
      		}

        cin
    
RC: cancellation support for promises + tests

              r145
            
              public static IPromise<T> Invoke<T>(Func<ICancellationToken, T> func) {

                  var p = new Promise<T>();

                  var caller = TraceContext.Instance.CurrentOperation;

                  ThreadPool.QueueUserWorkItem(param => {

                      TraceContext.Instance.EnterLogicalOperation(caller,false);

                      try {

                          p.Resolve(func(p));

                      } catch(Exception e) {

                          p.Reject(e);

                      } finally {

                          TraceContext.Instance.Leave();

                      }

                  });

                  return p;

              }

        cin
    
major update, added Drain mathod to AsyncQueue class

              r124
            
              public static IPromise<T> RunThread<T>(Func<T> func) {

        cin
    
Implemented interllocked queue...

              r14
            
                  var p = new Promise<T>();

        cin
    
rewritten tracing

              r92
            
                  var caller = TraceContext.Instance.CurrentOperation;

        cin
    
initial log capabilities

              r35
            
        cin
    
Implemented interllocked queue...

              r14
            
                  var worker = new Thread(() => {

        cin
    
rewritten tracing

              r92
            
                      TraceContext.Instance.EnterLogicalOperation(caller,false);

        cin
    
Implemented interllocked queue...

              r14
            
                      try {

                          p.Resolve(func());

                      } catch (Exception e) {

                          p.Reject(e);

        cin
    
rewritten tracing

              r92
            
                      } finally {

                          TraceContext.Instance.Leave();

        cin
    
Implemented interllocked queue...

              r14
            
                      }

                  });

                  worker.IsBackground = true;

                  worker.Start();

                  return p;

        cin
    
refactoring

              r25
            
              }

        cin
    
Interactive tracing...

              r48
            
        cin
    
RC: cancellation support for promises + tests

              r145
            
              public static IPromise<T> RunThread<T>(Func<ICancellationToken, T> func) {

                  var p = new Promise<T>();

                  var caller = TraceContext.Instance.CurrentOperation;

                  var worker = new Thread(() => {

                      TraceContext.Instance.EnterLogicalOperation(caller,false);

                      try {

                          p.Resolve(func(p));

                      } catch (Exception e) {

                          p.Reject(e);

                      } finally {

                          TraceContext.Instance.Leave();

                      }

                  });

                  worker.IsBackground = true;

                  worker.Start();

                  return p;

              }

        cin
    
Interactive tracing...

              r48
            
        cin
    
major update, added Drain mathod to AsyncQueue class

              r124
            
              public static IPromise RunThread(Action func) {

        cin
    
Promises rewritten, added improved version of AsyncQueue

              r119
            
                  var p = new Promise();

        cin
    
Interactive tracing...

              r48
            
        cin
    
rewritten tracing

              r92
            
                  var caller = TraceContext.Instance.CurrentOperation;

        cin
    
Interactive tracing...

              r48
            
                  var worker = new Thread(() => {

        cin
    
rewritten tracing

              r92
            
                      TraceContext.Instance.EnterLogicalOperation(caller,false);

        cin
    
Interactive tracing...

              r48
            
                      try {

                          func();

                          p.Resolve();

                      } catch (Exception e) {

                          p.Reject(e);

        cin
    
rewritten tracing

              r92
            
                      } finally {

                          TraceContext.Instance.Leave();

        cin
    
Interactive tracing...

              r48
            
                      }

                  });

                  worker.IsBackground = true;

                  worker.Start();

                  return p;

              }

        cin
    
improved asyncpool usability...

              r120
            
        cin
    
RC: cancellation support for promises + tests

              r145
            
              public static IPromise RunThread(Action<ICancellationToken> func) {

                  var p = new Promise();

                  var caller = TraceContext.Instance.CurrentOperation;

                  var worker = new Thread(() => {

                      TraceContext.Instance.EnterLogicalOperation(caller,false);

                      try {

                          func(p);

                          p.Resolve();

                      } catch (Exception e) {

                          p.Reject(e);

                      } finally {

                          TraceContext.Instance.Leave();

                      }

                  });

                  worker.IsBackground = true;

                  worker.Start();

                  return p;

              }

        cin
    
working version of AsyncQueue and batch operations...

              r121
            
              public static IPromise[] RunThread(params Action[] func) {

        cin
    
major update, added Drain mathod to AsyncQueue class

              r124
            
                  return func.Select(f => RunThread(f)).ToArray();

        cin
    
improved asyncpool usability...

              r120
            
              }

        cin
    
RC: cancellation support for promises + tests

              r145
            
              public static IPromise[] RunThread(params Action<ICancellationToken>[] func) {

                  return func.Select(f => RunThread(f)).ToArray();

              }

        cin
    
working version of AsyncQueue and batch operations...

              r121
            
              public static IPromise<T>[] RunThread<T>(params Func<T>[] func) {

        cin
    
major update, added Drain mathod to AsyncQueue class

              r124
            
                  return func.Select(f => RunThread(f)).ToArray();

        cin
    
improved asyncpool usability...

              r120
            
              }

        cin
    
RC: cancellation support for promises + tests

              r145
            
              public static IPromise<T>[] RunThread<T>(params Func<ICancellationToken, T>[] func) {

                  return func.Select(f => RunThread(f)).ToArray();

              }

        cin
    
refactoring

              r25
            
      	}

      }

	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

cin initial log capabilities	r35	using Implab.Diagnostics;
cin refactoring	r25	using System;
		using System.Threading;
cin improved asyncpool usability...	r120	using System.Linq;
cin refactoring	r25
		namespace Implab.Parallels {
		/// <summary>
		/// Класс для распаралеливания задач.
		/// </summary>
		/// <remarks>
		/// Используя данный класс и лямда выражения можно распараллелить
		/// вычисления, для этого используется концепция обещаний.
		/// </remarks>
		public static class AsyncPool {

cin initial work on interactive logger	r45	public static IPromise<T> Invoke<T>(Func<T> func) {
cin refactoring	r25	var p = new Promise<T>();
cin rewritten tracing	r92	var caller = TraceContext.Instance.CurrentOperation;
cin refactoring	r25
		ThreadPool.QueueUserWorkItem(param => {
cin rewritten tracing	r92	TraceContext.Instance.EnterLogicalOperation(caller,false);
cin refactoring	r25	try {
cin Implemented interllocked queue...	r14	p.Resolve(func());
cin refactoring	r25	} catch(Exception e) {
		p.Reject(e);
cin rewritten tracing	r92	} finally {
		TraceContext.Instance.Leave();
		}
cin refactoring	r25	});

		return p;
cin Implemented interllocked queue...	r14	}

cin RC: cancellation support for promises + tests	r145	public static IPromise<T> Invoke<T>(Func<ICancellationToken, T> func) {
		var p = new Promise<T>();
		var caller = TraceContext.Instance.CurrentOperation;

		ThreadPool.QueueUserWorkItem(param => {
		TraceContext.Instance.EnterLogicalOperation(caller,false);
		try {
		p.Resolve(func(p));
		} catch(Exception e) {
		p.Reject(e);
		} finally {
		TraceContext.Instance.Leave();
		}
		});

		return p;
		}

cin major update, added Drain mathod to AsyncQueue class	r124	public static IPromise<T> RunThread<T>(Func<T> func) {
cin Implemented interllocked queue...	r14	var p = new Promise<T>();

cin rewritten tracing	r92	var caller = TraceContext.Instance.CurrentOperation;
cin initial log capabilities	r35
cin Implemented interllocked queue...	r14	var worker = new Thread(() => {
cin rewritten tracing	r92	TraceContext.Instance.EnterLogicalOperation(caller,false);
cin Implemented interllocked queue...	r14	try {
		p.Resolve(func());
		} catch (Exception e) {
		p.Reject(e);
cin rewritten tracing	r92	} finally {
		TraceContext.Instance.Leave();
cin Implemented interllocked queue...	r14	}
		});
		worker.IsBackground = true;
		worker.Start();

		return p;
cin refactoring	r25	}
cin Interactive tracing...	r48
cin RC: cancellation support for promises + tests	r145	public static IPromise<T> RunThread<T>(Func<ICancellationToken, T> func) {
		var p = new Promise<T>();

		var caller = TraceContext.Instance.CurrentOperation;

		var worker = new Thread(() => {
		TraceContext.Instance.EnterLogicalOperation(caller,false);
		try {
		p.Resolve(func(p));
		} catch (Exception e) {
		p.Reject(e);
		} finally {
		TraceContext.Instance.Leave();
		}
		});
		worker.IsBackground = true;
		worker.Start();

		return p;
		}

cin Interactive tracing...	r48
cin major update, added Drain mathod to AsyncQueue class	r124	public static IPromise RunThread(Action func) {
cin Promises rewritten, added improved version of AsyncQueue	r119	var p = new Promise();
cin Interactive tracing...	r48
cin rewritten tracing	r92	var caller = TraceContext.Instance.CurrentOperation;
cin Interactive tracing...	r48
		var worker = new Thread(() => {
cin rewritten tracing	r92	TraceContext.Instance.EnterLogicalOperation(caller,false);
cin Interactive tracing...	r48	try {
		func();
		p.Resolve();
		} catch (Exception e) {
		p.Reject(e);
cin rewritten tracing	r92	} finally {
		TraceContext.Instance.Leave();
cin Interactive tracing...	r48	}
		});
		worker.IsBackground = true;
		worker.Start();

		return p;
		}
cin improved asyncpool usability...	r120
cin RC: cancellation support for promises + tests	r145	public static IPromise RunThread(Action<ICancellationToken> func) {
		var p = new Promise();

		var caller = TraceContext.Instance.CurrentOperation;

		var worker = new Thread(() => {
		TraceContext.Instance.EnterLogicalOperation(caller,false);
		try {
		func(p);
		p.Resolve();
		} catch (Exception e) {
		p.Reject(e);
		} finally {
		TraceContext.Instance.Leave();
		}
		});
		worker.IsBackground = true;
		worker.Start();

		return p;
		}

cin working version of AsyncQueue and batch operations...	r121	public static IPromise[] RunThread(params Action[] func) {
cin major update, added Drain mathod to AsyncQueue class	r124	return func.Select(f => RunThread(f)).ToArray();
cin improved asyncpool usability...	r120	}

cin RC: cancellation support for promises + tests	r145	public static IPromise[] RunThread(params Action<ICancellationToken>[] func) {
		return func.Select(f => RunThread(f)).ToArray();
		}

cin working version of AsyncQueue and batch operations...	r121	public static IPromise<T>[] RunThread<T>(params Func<T>[] func) {
cin major update, added Drain mathod to AsyncQueue class	r124	return func.Select(f => RunThread(f)).ToArray();
cin improved asyncpool usability...	r120	}
cin RC: cancellation support for promises + tests	r145
		public static IPromise<T>[] RunThread<T>(params Func<ICancellationToken, T>[] func) {
		return func.Select(f => RunThread(f)).ToArray();
		}
cin refactoring	r25	}
		}