implab/ImplabNet Files · Implab/AbstractTaskT.cs

Bound promise to CancellationToken...

Bound promise to CancellationToken Added new states to ExecutionSate enum. Added Safe.Guard() method to handle cleanup of the result of the promise

cin - - Load All Authors

File last commit:

r187:dd4a3590f9c6 ref20160224


                r209:a867536c68fc

Download file

             AbstractTaskT.cs
        
                    36 lines
            
             | 1.3 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / AbstractTaskT.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 {

          public abstract class AbstractTask<T> : AbstractPromise<T> {

              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 {
		public abstract class AbstractTask<T> : AbstractPromise<T> {
		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)
		);
		}
		}
		}