implab/ImplabNet Files · Implab/AbstractTask.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:

r187:dd4a3590f9c6 ref20160224


                r203:4d9830a9bbb8

Download file

             AbstractTask.cs
        
                    45 lines
            
             | 2.0 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / AbstractTask.cs
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
Reworked cancelation handling, if the cancel handler isn't specified the OperationCanceledException will be handled by the error handler...

              r187
            
      using System;

      using System.Threading;

      namespace Implab {

          /// <summary>

          /// Базовый класс для реализации задачь. Задача представляет собой некторое

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

          ///  в виде обещания, для этого оно реализует интерфейс <see cref="IPromise"/>.

          /// </summary>

          /// <remarks>

          /// Данный класс определяет стандартное поведение при обработки результатов, в частности

          /// обработку <see cref="System.OperationCanceledException"/> и <see cref="PromiseTransientException"/>

          /// </remarks>

          public abstract class AbstractTask : AbstractPromise {

              int m_cancelationLock;

              /// <summary>

              /// Получает эксклюзивное право отмены задания, используется для отмены задания до начала его выполнения.

              /// </summary>

              /// <returns><c>true</c>, if cancelation was locked, <c>false</c> otherwise.</returns>

              protected bool LockCancelation() {

                  return 0 == Interlocked.CompareExchange(ref m_cancelationLock, 1, 0);

              }

              protected void SetErrorInternal(Exception error) {

                  // unwrap 

                  while (error is PromiseTransientException && error.InnerException != null)

                      error = error.InnerException;

                  if (error is OperationCanceledException)

                      SetCancelled(error);

                  else

                      SetError(error);

              }

              protected void SetCancelledInternal(Exception reason) {

                  SetCancelled(

                      reason == null ? new OperationCanceledException() : reason is OperationCanceledException ? reason : new OperationCanceledException(null, reason)

                  );

              }

          }

      }

	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 Reworked cancelation handling, if the cancel handler isn't specified the OperationCanceledException will be handled by the error handler...	r187	using System;
		using System.Threading;

		namespace Implab {
		/// <summary>
		/// Базовый класс для реализации задачь. Задача представляет собой некторое
		/// действие, которое можно иницировать и обработать результат его выполнения
		/// в виде обещания, для этого оно реализует интерфейс <see cref="IPromise"/>.
		/// </summary>
		/// <remarks>
		/// Данный класс определяет стандартное поведение при обработки результатов, в частности
		/// обработку <see cref="System.OperationCanceledException"/> и <see cref="PromiseTransientException"/>
		/// </remarks>
		public abstract class AbstractTask : AbstractPromise {
		int m_cancelationLock;

		/// <summary>
		/// Получает эксклюзивное право отмены задания, используется для отмены задания до начала его выполнения.
		/// </summary>
		/// <returns><c>true</c>, if cancelation was locked, <c>false</c> otherwise.</returns>
		protected bool LockCancelation() {
		return 0 == Interlocked.CompareExchange(ref m_cancelationLock, 1, 0);
		}



		protected void SetErrorInternal(Exception error) {
		// unwrap
		while (error is PromiseTransientException && error.InnerException != null)
		error = error.InnerException;

		if (error is OperationCanceledException)
		SetCancelled(error);
		else
		SetError(error);
		}

		protected void SetCancelledInternal(Exception reason) {
		SetCancelled(
		reason == null ? new OperationCanceledException() : reason is OperationCanceledException ? reason : new OperationCanceledException(null, reason)
		);
		}
		}
		}