implab/ImplabNet Files · Implab/AbstractTask.cs

Code review, added a non generic version of SyncContextPromise

cin - - Load All Authors

File last commit:

r187:dd4a3590f9c6 ref20160224


                r211:3eb3255d8cc5

Download file

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

      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

				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)
				);
				}
				}
				}