implab/ImplabNet Commit - r104:5f10d54b45df

renamed Promise.Last -> Promise.On...

cin -

r104:5f10d54b45df v2

parent child

Context file:

r104:5f10d54b45df

Collapse all files

Implab/PromiseEventType.cs created 644 +19 0

@@ -0,0 +1,19
	1	using System;
	2
	3	namespace Implab {
	4	[Flags]
	5	public enum PromiseEventType {
	6	Success = 1,
	7	Error = 2,
	8	Cancelled = 4,
	9	/// <summary>
	10	/// Завершено успешно, либо возникла ошибка,
	11	/// </summary>
	12	All = 7,
	13	/// <summary>
	14	/// Заврешено успешно, либо возникла ошибка.
	15	/// </summary>
	16	Complete = 3
	17	}
	18	}
	19

Implab.Fx/PromiseHelpers.cs +1 -1

             using System;
             using System.Windows.Forms;
             using System.Threading;
             namespace Implab.Fx
             {
                 public static class PromiseHelpers
                 {
                     /// <summary>
                     /// Перенаправляет обработку обещания в поток указанного элемента управления.
                     /// </summary>
                     /// <typeparam name="T">Тип результата обещания</typeparam>
                     /// <param name="that">Исходное обещание</param>
                     /// <param name="ctl">Элемент управления</param>
                     /// <returns>Новое обещание, обработчики которого будут выполнены в потоке элемента управления.</returns>
                     /// <exception cref="ArgumentNullException">Параметр не может быть <c>null</c>.</exception>
                     /// <example>
                     /// client
                     ///     .Get("description.txt") // returns a promise
                     ///     .DispatchToControl(m_ctl) // handle the promise in the thread of the control
                     ///     .Then(
                     ///         description => m_ctl.Text = description // now it's safe
                     ///     )
                     /// </example>
                     public static IPromise<T> DispatchToControl<T>(this IPromise<T> that, Control ctl)
                     {
                         Safe.ArgumentNotNull(that, "that");
                         Safe.ArgumentNotNull(ctl, "ctl");
                         var directed = new ControlBoundPromise<T>(ctl,that);
-                        that.Last(
+                        that.On(
                             directed.Resolve,
                             directed.Reject,
                             directed.Cancel
                         );
                         return directed;
                     }
                 }
             }

Implab/IPromise.cs +4 -3

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             namespace Implab {
                 public interface IPromise: ICancellable {
                     /// <summary>
                     /// Check whereather the promise has no more than one dependent promise.
                     /// </summary>
                     bool IsExclusive {
                         get;
                     }
                     /// <summary>
                     /// Тип результата, получаемого через данное обещание.
                     /// </summary>
                     Type PromiseType { get; }
                     /// <summary>
                     /// Обещание является выполненым, либо успешно, либо с ошибкой, либо отменено.
                     /// </summary>
                     bool IsResolved { get; }
                     /// <summary>
                     /// Обещание было отменено.
                     /// </summary>
                     bool IsCancelled { get; }
                     IPromise Then(Action success, Action<Exception> error, Action cancel);
                     IPromise Then(Action success, Action<Exception> error);
                     IPromise Then(Action success);
                     IPromise Chain(Func<IPromise> chained, Func<Exception, IPromise> error, Action cancel);
                     IPromise Chain(Func<IPromise> chained, Func<Exception, IPromise> error);
                     IPromise Chain(Func<IPromise> chained);
                     /// <summary>
                     /// Добавляет последнй обработчик в цепочку обещаний, не создает промежуточных обещаний.
                     /// </summary>
                     /// <param name="success">Success.</param>
                     /// <param name="error">Error.</param>
                     /// <param name="cancel">Cancel.</param>
-                    void Last(Action success, Action<Exception> error, Action cancel);
+                    void On(Action success, Action<Exception> error, Action cancel);
-                    void Last(Action success, Action<Exception> error);
+                    void On(Action success, Action<Exception> error);
-                    void Last(Action success);
+                    void On(Action success);
+                    void On(Action success, PromiseEventType events);
                     IPromise Error(Action<Exception> error);
                     /// <summary>
                     /// Обрабатывает либо ошибку, либо результат, либо отмену.
                     /// </summary>
                     /// <param name="handler">Обработчик.</param>
                     /// <remarks>После обработке ошибки, она передается дальше.</remarks>
                     /// <summary>
                     /// Обрабатывает либо ошибку, либо результат, либо отмену обещания.
                     /// </summary>
                     /// <param name="handler">Обработчик.</param>
                     /// <remarks>После обработке ошибки, она передается дальше.</remarks>
                     IPromise Anyway(Action handler);
                     /// <summary>
                     /// Обработчик для регистрации отмены обещания.
                     /// </summary>
                     /// <returns>Новое обещание, связанное с текущим, выполнится после указанного обработчика.</returns>
                     /// <param name="handler">Обработчик события.</param>
                     /// <remarks>Если обработчик вызывает исключение, то оно передается обработчику ошибки, результат работы
                     /// которого будет передан связанному обещанию</remarks>
                     IPromise Cancelled(Action handler);
                     /// <summary>
                     /// Преобразует результат обещания к заданному типу и возвращает новое обещание.
                     /// </summary>
                     IPromise<T> Cast<T>();
                     /// <summary>
                     /// Синхронизирует текущий поток с обещанием.
                     /// </summary>
                     void Join();
                     /// <summary>
                     /// Синхронизирует текущий поток с обещанием.
                     /// </summary>
                     /// <param name="timeout">Время ожидания, по его истечению возникнет исключение.</param>
                     /// <exception cref="TimeoutException">Превышено время ожидания.</exception>
                     void Join(int timeout);
                 }
             }

Implab/IPromiseT.cs +3 -3

             using System;
             namespace Implab {
                 public interface IPromise<T> : IPromise {
                     new T Join();
                     new T Join(int timeout);
-                    void Last(Action<T> success, Action<Exception> error, Action cancel);
+                    void On(Action<T> success, Action<Exception> error, Action cancel);
-                    void Last(Action<T> success, Action<Exception> error);
+                    void On(Action<T> success, Action<Exception> error);
-                    void Last(Action<T> success);
+                    void On(Action<T> success);
                     IPromise<T> Then(Action<T> success, Func<Exception,T> error, Action cancel);
                     IPromise<T> Then(Action<T> success, Func<Exception,T> error);
                     IPromise<T> Then(Action<T> success);
                     IPromise<T2> Then<T2>(Func<T, T2> mapper, Func<Exception,T2> error, Action cancel);
                     IPromise<T2> Then<T2>(Func<T, T2> mapper, Func<Exception,T2> error);
                     IPromise<T2> Then<T2>(Func<T, T2> mapper);
                     IPromise<T2> Chain<T2>(Func<T, IPromise<T2>> chained, Func<Exception,IPromise<T2>> error, Action cancel);
                     IPromise<T2> Chain<T2>(Func<T, IPromise<T2>> chained, Func<Exception,IPromise<T2>> error);
                     IPromise<T2> Chain<T2>(Func<T, IPromise<T2>> chained);
                     IPromise<T> Error(Func<Exception,T> error);
                     new IPromise<T> Cancelled(Action handler);
                     new IPromise<T> Anyway(Action handler);
                 }
             }

Implab/Implab.csproj +1 0

             <?xml version="1.0" encoding="utf-8"?>
             <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
               <PropertyGroup>
                 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
                 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
                 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
                 <OutputType>Library</OutputType>
                 <RootNamespace>Implab</RootNamespace>
                 <AssemblyName>Implab</AssemblyName>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
                 <DefineConstants>TRACE;DEBUG;</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
                 <RunCodeAnalysis>true</RunCodeAnalysis>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
                 <DebugType>full</DebugType>
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug 4.5|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
                 <DefineConstants>TRACE;DEBUG;NET_4_5</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <RunCodeAnalysis>true</RunCodeAnalysis>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release 4.5|AnyCPU' ">
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
                 <DefineConstants>NET_4_5</DefineConstants>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'DebugMono|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
                 <DefineConstants>TRACE;DEBUG;NET_4_5;MONO</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <RunCodeAnalysis>true</RunCodeAnalysis>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'ReleaseMono|AnyCPU' ">
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <DefineConstants>NET_4_5;MONO;</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <ItemGroup>
                 <Reference Include="System" />
                 <Reference Include="System.Xml" />
               </ItemGroup>
               <ItemGroup>
                 <Compile Include="Component.cs" />
                 <Compile Include="CustomEqualityComparer.cs" />
                 <Compile Include="Diagnostics\ConsoleTraceListener.cs" />
                 <Compile Include="Diagnostics\EventText.cs" />
                 <Compile Include="Diagnostics\IEventTextFormatter.cs" />
                 <Compile Include="Diagnostics\LogChannel.cs" />
                 <Compile Include="Diagnostics\LogicalOperation.cs" />
                 <Compile Include="Diagnostics\TextFileListener.cs" />
                 <Compile Include="Diagnostics\TextListenerBase.cs" />
                 <Compile Include="Diagnostics\TraceLog.cs" />
                 <Compile Include="Diagnostics\TraceEvent.cs" />
                 <Compile Include="Diagnostics\TraceEventType.cs" />
                 <Compile Include="Disposable.cs" />
                 <Compile Include="ICancellable.cs" />
                 <Compile Include="IProgressHandler.cs" />
                 <Compile Include="IProgressNotifier.cs" />
                 <Compile Include="IPromiseT.cs" />
                 <Compile Include="IPromise.cs" />
                 <Compile Include="IServiceLocator.cs" />
                 <Compile Include="ITaskController.cs" />
                 <Compile Include="JSON\JSONElementContext.cs" />
                 <Compile Include="JSON\JSONElementType.cs" />
                 <Compile Include="JSON\JSONGrammar.cs" />
                 <Compile Include="JSON\JSONParser.cs" />
                 <Compile Include="JSON\JSONScanner.cs" />
                 <Compile Include="JSON\JsonTokenType.cs" />
                 <Compile Include="JSON\JSONWriter.cs" />
                 <Compile Include="JSON\JSONXmlReader.cs" />
                 <Compile Include="JSON\JSONXmlReaderOptions.cs" />
                 <Compile Include="JSON\StringTranslator.cs" />
                 <Compile Include="Parallels\DispatchPool.cs" />
                 <Compile Include="Parallels\ArrayTraits.cs" />
                 <Compile Include="Parallels\MTQueue.cs" />
                 <Compile Include="Parallels\WorkerPool.cs" />
                 <Compile Include="Parsing\Alphabet.cs" />
                 <Compile Include="Parsing\AlphabetBase.cs" />
                 <Compile Include="Parsing\AltToken.cs" />
                 <Compile Include="Parsing\BinaryToken.cs" />
                 <Compile Include="Parsing\CatToken.cs" />
                 <Compile Include="Parsing\CDFADefinition.cs" />
                 <Compile Include="Parsing\DFABuilder.cs" />
                 <Compile Include="Parsing\DFADefinitionBase.cs" />
                 <Compile Include="Parsing\DFAStateDescriptor.cs" />
                 <Compile Include="Parsing\DFAutomaton.cs" />
                 <Compile Include="Parsing\EDFADefinition.cs" />
                 <Compile Include="Parsing\EmptyToken.cs" />
                 <Compile Include="Parsing\EndToken.cs" />
                 <Compile Include="Parsing\EnumAlphabet.cs" />
                 <Compile Include="Parsing\Grammar.cs" />
                 <Compile Include="Parsing\IAlphabet.cs" />
                 <Compile Include="Parsing\IDFADefinition.cs" />
                 <Compile Include="Parsing\IVisitor.cs" />
                 <Compile Include="Parsing\ParserException.cs" />
                 <Compile Include="Parsing\Scanner.cs" />
                 <Compile Include="Parsing\StarToken.cs" />
                 <Compile Include="Parsing\SymbolToken.cs" />
                 <Compile Include="Parsing\Token.cs" />
                 <Compile Include="SafePool.cs" />
                 <Compile Include="ServiceLocator.cs" />
                 <Compile Include="TaskController.cs" />
                 <Compile Include="ProgressInitEventArgs.cs" />
                 <Compile Include="Properties\AssemblyInfo.cs" />
                 <Compile Include="Promise.cs" />
                 <Compile Include="Parallels\AsyncPool.cs" />
                 <Compile Include="Safe.cs" />
                 <Compile Include="ValueEventArgs.cs" />
                 <Compile Include="PromiseExtensions.cs" />
                 <Compile Include="TransientPromiseException.cs" />
                 <Compile Include="SyncContextPromise.cs" />
                 <Compile Include="ObjectPool.cs" />
                 <Compile Include="Diagnostics\OperationContext.cs" />
                 <Compile Include="Diagnostics\TraceContext.cs" />
                 <Compile Include="Diagnostics\LogEventArgs.cs" />
                 <Compile Include="Diagnostics\LogEventArgsT.cs" />
                 <Compile Include="Diagnostics\Extensions.cs" />
                 <Compile Include="IComponentContainer.cs" />
                 <Compile Include="MTComponentContainer.cs" />
+                <Compile Include="PromiseEventType.cs" />
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <ItemGroup />
               <ProjectExtensions>
                 <MonoDevelop>
                   <Properties>
                     <Policies>
                       <CSharpFormattingPolicy IndentSwitchBody="True" NamespaceBraceStyle="EndOfLine" ClassBraceStyle="EndOfLine" InterfaceBraceStyle="EndOfLine" StructBraceStyle="EndOfLine" EnumBraceStyle="EndOfLine" MethodBraceStyle="EndOfLine" ConstructorBraceStyle="EndOfLine" DestructorBraceStyle="EndOfLine" BeforeMethodDeclarationParentheses="False" BeforeMethodCallParentheses="False" BeforeConstructorDeclarationParentheses="False" NewLineBeforeConstructorInitializerColon="NewLine" NewLineAfterConstructorInitializerColon="SameLine" BeforeIndexerDeclarationBracket="False" BeforeDelegateDeclarationParentheses="False" NewParentheses="False" SpacesBeforeBrackets="False" inheritsSet="Mono" inheritsScope="text/x-csharp" scope="text/x-csharp" />
                       <TextStylePolicy FileWidth="120" EolMarker="Unix" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/x-csharp" />
                       <DotNetNamingPolicy DirectoryNamespaceAssociation="PrefixedHierarchical" ResourceNamePolicy="MSBuild" />
                       <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="application/xml" />
                       <XmlFormattingPolicy inheritsSet="Mono" inheritsScope="application/xml" scope="application/xml" />
                       <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/plain" />
                       <NameConventionPolicy>
                         <Rules>
                           <NamingRule Name="Namespaces" AffectedEntity="Namespace" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Types" AffectedEntity="Class, Struct, Enum, Delegate" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Interfaces" AffectedEntity="Interface" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredPrefixes>
                               <String>I</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="Attributes" AffectedEntity="CustomAttributes" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredSuffixes>
                               <String>Attribute</String>
                             </RequiredSuffixes>
                           </NamingRule>
                           <NamingRule Name="Event Arguments" AffectedEntity="CustomEventArgs" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredSuffixes>
                               <String>EventArgs</String>
                             </RequiredSuffixes>
                           </NamingRule>
                           <NamingRule Name="Exceptions" AffectedEntity="CustomExceptions" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredSuffixes>
                               <String>Exception</String>
                             </RequiredSuffixes>
                           </NamingRule>
                           <NamingRule Name="Methods" AffectedEntity="Methods" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Static Readonly Fields" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Protected, Public" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True" />
                           <NamingRule Name="Fields (Non Private)" AffectedEntity="Field" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="ReadOnly Fields (Non Private)" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False" />
                           <NamingRule Name="Fields (Private)" AffectedEntity="Field, ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False">
                             <RequiredPrefixes>
                               <String>m_</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="Static Fields (Private)" AffectedEntity="Field" VisibilityMask="Private" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True">
                             <RequiredPrefixes>
                               <String>_</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="ReadOnly Fields (Private)" AffectedEntity="ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False">
                             <RequiredPrefixes>
                               <String>m_</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="Constant Fields" AffectedEntity="ConstantField" VisibilityMask="VisibilityMask" NamingStyle="AllUpper" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Properties" AffectedEntity="Property" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Events" AffectedEntity="Event" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Enum Members" AffectedEntity="EnumMember" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Parameters" AffectedEntity="Parameter, LocalVariable" VisibilityMask="VisibilityMask" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Type Parameters" AffectedEntity="TypeParameter" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredPrefixes>
                               <String>T</String>
                             </RequiredPrefixes>
                           </NamingRule>
                         </Rules>
                       </NameConventionPolicy>
                     </Policies>
                   </Properties>
                 </MonoDevelop>
               </ProjectExtensions>
             </Project>

Implab/Parallels/ArrayTraits.cs +1 -1

             using Implab.Diagnostics;
             using System;
             using System.Diagnostics;
             using System.Threading;
             namespace Implab.Parallels {
                 public static class ArrayTraits {
                     class ArrayIterator<TSrc> : DispatchPool<int> {
                         readonly Action<TSrc> m_action;
                         readonly TSrc[] m_source;
                         readonly Promise<int> m_promise = new Promise<int>();
                         readonly LogicalOperation m_logicalOperation;
                         int m_pending;
                         int m_next;
                         public ArrayIterator(TSrc[] source, Action<TSrc> action, int threads)
                             : base(threads) {
                             Debug.Assert(source != null);
                             Debug.Assert(action != null);
                             m_logicalOperation = TraceContext.Instance.CurrentOperation;
                             m_next = 0;
                             m_source = source;
                             m_pending = source.Length;
                             m_action = action;
                             m_promise.Anyway(Dispose);
                             InitPool();
                         }
                         public Promise<int> Promise {
                             get {
                                 return m_promise;
                             }
                         }
                         protected override void Worker() {
                             TraceContext.Instance.EnterLogicalOperation(m_logicalOperation, false);
                             try {
                                 base.Worker();
                             } finally {
                                 TraceContext.Instance.Leave();
                             }
                         }
                         protected override bool TryDequeue(out int unit) {
                             unit = Interlocked.Increment(ref m_next) - 1;
                             return unit < m_source.Length;
                         }
                         protected override void InvokeUnit(int unit) {
                             try {
                                 m_action(m_source[unit]);
                                 var pending = Interlocked.Decrement(ref m_pending);
                                 if (pending == 0)
                                     m_promise.Resolve(m_source.Length);
                             } catch (Exception e) {
                                 m_promise.Reject(e);
                             }
                         }
                     }
                     class ArrayMapper<TSrc, TDst>: DispatchPool<int> {
                         readonly Func<TSrc, TDst> m_transform;
                         readonly TSrc[] m_source;
                         readonly TDst[] m_dest;
                         readonly Promise<TDst[]> m_promise = new Promise<TDst[]>();
                         readonly LogicalOperation m_logicalOperation;
                         int m_pending;
                         int m_next;
                         public ArrayMapper(TSrc[] source, Func<TSrc, TDst> transform, int threads)
                             : base(threads) {
                             Debug.Assert (source != null);
                             Debug.Assert( transform != null);
                             m_next = 0;
                             m_source = source;
                             m_dest = new TDst[source.Length];
                             m_pending = source.Length;
                             m_transform = transform;
                             m_logicalOperation = TraceContext.Instance.CurrentOperation;
                             m_promise.Anyway(Dispose);
                             InitPool();
                         }
                         public Promise<TDst[]> Promise {
                             get {
                                 return m_promise;
                             }
                         }
                         protected override void Worker() {
                             TraceContext.Instance.EnterLogicalOperation(m_logicalOperation,false);
                             try {
                                 base.Worker();
                             } finally {
                                 TraceContext.Instance.Leave();
                             }
                         }
                         protected override bool TryDequeue(out int unit) {
                             unit = Interlocked.Increment(ref m_next) - 1;
                             return unit < m_source.Length;
                         }
                         protected override void InvokeUnit(int unit) {
                             try {
                                 m_dest[unit] = m_transform(m_source[unit]);
                                 var pending = Interlocked.Decrement(ref m_pending);
                                 if (pending == 0)
                                     m_promise.Resolve(m_dest);
                             } catch (Exception e) {
                                 m_promise.Reject(e);
                             }
                         }
                     }
                     public static IPromise<TDst[]> ParallelMap<TSrc, TDst> (this TSrc[] source, Func<TSrc,TDst> transform, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (transform == null)
                             throw new ArgumentNullException("transform");
                         var mapper = new ArrayMapper<TSrc, TDst>(source, transform, threads);
                         return mapper.Promise;
                     }
                     public static IPromise<int> ParallelForEach<TSrc>(this TSrc[] source, Action<TSrc> action, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (action == null)
                             throw new ArgumentNullException("action");
                         var iter = new ArrayIterator<TSrc>(source, action, threads);
                         return iter.Promise;
                     }
                     public static IPromise<TDst[]> ChainedMap<TSrc, TDst>(this TSrc[] source, Func<TSrc, IPromise<TDst>> transform, int threads) {
                         if (source == null)
                             throw new ArgumentNullException("source");
                         if (transform == null)
                             throw new ArgumentNullException("transform");
                         if (threads <= 0)
                             throw new ArgumentOutOfRangeException("threads","Threads number must be greater then zero");
                         if (source.Length == 0)
                             return Promise<TDst[]>.ResultToPromise(new TDst[0]);
                         var promise = new Promise<TDst[]>();
                         var res = new TDst[source.Length];
                         var pending = source.Length;
                         object locker = new object();
                         int slots = threads;
                         // Analysis disable AccessToDisposedClosure
                         AsyncPool.InvokeNewThread(() => {
                             for (int i = 0; i < source.Length; i++) {
                                 if(promise.IsResolved)
                                     break; // stop processing in case of error or cancellation
                                 var idx = i;
                                 if (Interlocked.Decrement(ref slots) < 0) {
                                     lock(locker) {
                                         while(slots < 0)
                                             Monitor.Wait(locker);
                                     }
                                 }
                                 try {
                                     transform(source[i])
                                         .Anyway(() => {
                                             Interlocked.Increment(ref slots);
                                             lock (locker) {
                                                 Monitor.Pulse(locker);
                                             }
                                         })
-                                        .Last(
+                                        .On(
                                             x => {
                                                 res[idx] = x;
                                                 var left = Interlocked.Decrement(ref pending);
                                                 if (left == 0)
                                                     promise.Resolve(res);
                                             },
                                             promise.Reject
                                         );
                                 } catch (Exception e) {
                                     promise.Reject(e);
                                 }
                             }
                             return 0;
                         });
                         return promise;
                     }
                 }
             }

Implab/Promise.cs +89 -65

             using System;
             using System.Collections.Generic;
             using System.Reflection;
             using System.Threading;
             using Implab.Parallels;
             namespace Implab {
                 /// <summary>
                 /// Класс для асинхронного получения результатов. Так называемое "обещание".
                 /// </summary>
                 /// <typeparam name="T">Тип получаемого результата</typeparam>
                 /// <remarks>
                 /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,
                 /// клиент получив такое обещание может установить ряд обратных вызово для получения
                 /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>
                 /// <para>
                 /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на
                 /// данные события клиент должен использовать методы <c>Then</c>.
                 /// </para>
                 /// <para>
                 /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),
                 /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о
                 /// выполнении обещания.
                 /// </para>
                 /// <para>
                 /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,
                 /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном
                 /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в
                 /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении
                 /// обещания.
                 /// </para>
                 /// <para>
                 /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать
                 /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует
                 /// использовать соответствующую форму методе <c>Then</c>.
                 /// </para>
                 /// <para>
                 /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать
                 /// только инициатор обещания иначе могут возникнуть противоречия.
                 /// </para>
                 /// </remarks>
                 public class Promise<T> : IPromise<T> {
                     protected struct HandlerDescriptor {
                         public Action<T> resultHandler;
                         public Func<Exception,T> errorHandler;
                         public Action cancellHandler;
                         public Promise<T> medium;
                         public void Resolve(T result) {
                             if (resultHandler != null) {
                                 try {
                                     resultHandler(result);
                                 } catch (Exception e) {
                                     Reject(e);
                                     return;
                                 }
                             }
                             if (medium != null)
                                 medium.Resolve(result);
                         }
                         public void Reject(Exception err) {
                             if (errorHandler != null) {
                                 try {
                                     var res = errorHandler(err);
                                     if (medium != null)
                                         medium.Resolve(res);
                                     /*} catch (TransientPromiseException err2) {
                                     if (medium != null)
                                         medium.Reject(err2.InnerException);*/
                                 } catch (Exception err2) {
                                     if (medium != null)
                                         medium.Reject(err2);
                                 }
                             } else if (medium != null)
                                 medium.Reject(err);
                         }
                         public void Cancel() {
                             if (cancellHandler != null) {
                                 try {
                                     cancellHandler();
                                 } catch (Exception err) {
                                     Reject(err);
                                     return;
                                 }
                             }
                             if (medium != null)
                                 medium.Cancel();
                         }
                     }
                     const int UNRESOLVED_SATE = 0;
                     const int TRANSITIONAL_STATE = 1;
                     const int SUCCEEDED_STATE = 2;
                     const int REJECTED_STATE = 3;
                     const int CANCELLED_STATE = 4;
                     int m_childrenCount;
                     int m_state;
                     T m_result;
                     Exception m_error;
                     readonly MTQueue<HandlerDescriptor> m_handlers = new MTQueue<HandlerDescriptor>();
                     public Promise() {
                     }
                     public Promise(IPromise parent) {
                         if (parent != null)
                             AddHandler(
                                 null,
                                 null,
                                 () => {
                                     if (parent.IsExclusive)
                                         parent.Cancel();
                                 },
-                                null
+                                null,
+                                false
                             );
                     }
                     bool BeginTransit() {
                         return UNRESOLVED_SATE == Interlocked.CompareExchange(ref m_state, TRANSITIONAL_STATE, UNRESOLVED_SATE);
                     }
                     void CompleteTransit(int state) {
                         if (TRANSITIONAL_STATE != Interlocked.CompareExchange(ref m_state, state, TRANSITIONAL_STATE))
                             throw new InvalidOperationException("Can't complete transition when the object isn't in the transitional state");
                     }
                     void WaitTransition() {
                         while (m_state == TRANSITIONAL_STATE) {
                             Thread.MemoryBarrier();
                         }
                     }
                     public bool IsResolved {
                         get {
                             Thread.MemoryBarrier();
                             return m_state > 1;
                         }
                     }
                     public bool IsCancelled {
                         get {
                             Thread.MemoryBarrier();
                             return m_state == CANCELLED_STATE;
                         }
                     }
                     public Type PromiseType {
                         get { return typeof(T); }
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об успешном выполнении.
                     /// </summary>
                     /// <param name="result">Результат выполнения.</param>
                     /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
                     public void Resolve(T result) {
                         if (BeginTransit()) {
                             m_result = result;
                             CompleteTransit(SUCCEEDED_STATE);
                             OnStateChanged();
                         } else {
                             WaitTransition();
                             if (m_state != CANCELLED_STATE)
                                 throw new InvalidOperationException("The promise is already resolved");
                         }
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об успешном выполнении. Результатом выполнения будет пустое значения.
                     /// </summary>
                     /// <remarks>
                     /// Данный вариант удобен в случаях, когда интересен факт выполнения операции, нежели полученное значение.
                     /// </remarks>
                     public void Resolve() {
                         Resolve(default(T));
                     }
                     /// <summary>
                     /// Выполняет обещание, сообщая об ошибке
                     /// </summary>
                     /// <remarks>
                     /// Поскольку обещание должно работать в многопточной среде, при его выполнении сразу несколько потоков
                     /// могу вернуть ошибку, при этом только первая будет использована в качестве результата, остальные
                     /// будут проигнорированы.
                     /// </remarks>
                     /// <param name="error">Исключение возникшее при выполнении операции</param>
                     /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
                     public void Reject(Exception error) {
                         if (BeginTransit()) {
                             m_error = error is TransientPromiseException ? error.InnerException : error;
                             CompleteTransit(REJECTED_STATE);
                             OnStateChanged();
                         } else {
                             WaitTransition();
                             if (m_state == SUCCEEDED_STATE)
                                 throw new InvalidOperationException("The promise is already resolved");
                         }
                     }
                     /// <summary>
                     /// Отменяет операцию, если это возможно.
                     /// </summary>
                     /// <remarks>Для определения была ли операция отменена следует использовать свойство <see cref="IsCancelled"/>.</remarks>
                     public void Cancel() {
                         if (BeginTransit()) {
                             CompleteTransit(CANCELLED_STATE);
                             OnStateChanged();
                         }
                     }
                     public IPromise<T> Then(Action<T> success, Func<Exception,T> error, Action cancel) {
                         if (success == null && error == null && cancel == null)
                             return this;
                         var medium = new Promise<T>(this);
-                        AddHandler(success, error, cancel, medium);
+                        AddHandler(success, error, cancel, medium, true);
                         return medium;
                     }
                     /// <summary>
                     /// Adds new handlers to this promise.
                     /// </summary>
                     /// <param name="success">The handler of the successfully completed operation.
                     /// This handler will recieve an operation result as a parameter.</param>
                     /// <param name="error">Handles an exception that may occur during the operation and returns the value which will be used as the result of the operation.</param>
                     /// <returns>The new promise chained to this one.</returns>
                     public IPromise<T> Then(Action<T> success, Func<Exception,T> error) {
                         if (success == null && error == null)
                             return this;
                         var medium = new Promise<T>(this);
-                        AddHandler(success, error, null, medium);
+                        AddHandler(success, error, null, medium, true);
                         return medium;
                     }
                     public IPromise<T> Then(Action<T> success) {
                         if (success == null)
                             return this;
                         var medium = new Promise<T>(this);
-                        AddHandler(success, null, null, medium);
+                        AddHandler(success, null, null, medium, true);
                         return medium;
                     }
                     /// <summary>
                     /// Последний обработчик в цепочки обещаний.
                     /// </summary>
                     /// <param name="success"></param>
                     /// <param name="error"></param>
                     /// <param name="cancel"></param>
                     /// <remarks>
                     /// <para>
                     /// Данный метод не создает связанного с текущим обещания и предназначен для окончания
                     /// фсинхронной цепочки.
                     /// </para>
                     /// <para>
                     /// Если данный метод вызвать несколько раз, либо добавить другие обработчики, то цепочка
                     /// не будет одиночной <see cref="IsExclusive"/> и, как следствие, будет невозможна отмена
                     /// всей цепи обещаний снизу (с самого последнего обещания).
                     /// </para>
                     /// </remarks>
-                    public void Last(Action<T> success, Action<Exception> error, Action cancel) {
+                    public void On(Action<T> success, Action<Exception> error, Action cancel) {
                         if (success == null && error == null && cancel == null)
                             return;
                         Func<Exception,T> errorHandler = null;
                         if (error != null)
                             errorHandler = err => {
                                 error(err);
                                 return default(T);
                             };
-                        AddHandler(success, errorHandler, cancel, null);
+                        AddHandler(success, errorHandler, cancel, null, false);
+                    }
+                    public void On(Action<T> success, Action<Exception> error) {
+                        On(success, error, null);
+                    }
+                    public void On(Action<T> success) {
+                        On(success, null, null);
                     }
-                    public void Last(Action<T> success, Action<Exception> error) {
+                    public void On(Action handler, PromiseEventType events) {
-                        Last(success, error, null);
+                        Safe.ArgumentNotNull(handler, "handler");
-                    public void Last(Action<T> success) {
+                        Action<T> success = events.HasFlag(PromiseEventType.Success) ? new Action<T>(x => handler()) : null;
-                        Last(success, null, null);
+                        Func<Exception,T> error = events.HasFlag(PromiseEventType.Error) ? new Func<Exception,T>(e => {
+                            handler();
+                            return default(T);
+                        }) : null;
+                        Action cancel = events.HasFlag(PromiseEventType.Cancelled) ? handler : null;
+                        AddHandler(success, error, cancel, null, false);
                     }
                     public IPromise Error(Action<Exception> error) {
                         if (error == null)
                             return this;
                         var medium = new Promise<T>(this);
                         AddHandler(
                             null,
                             e => {
                                 error(e);
                                 return default(T);
                             },
                             null,
-                            medium
+                            medium,
+                            true
                         );
                         return medium;
                     }
                     /// <summary>
                     /// Handles error and allows to keep the promise.
                     /// </summary>
                     /// <remarks>
                     /// If the specified handler throws an exception, this exception will be used to reject the promise.
                     /// </remarks>
                     /// <param name="handler">The error handler which returns the result of the promise.</param>
                     /// <returns>New promise.</returns>
                     public IPromise<T> Error(Func<Exception,T> handler) {
                         if (handler == null)
                             return this;
                         var medium = new Promise<T>(this);
-                        AddHandler(null, handler, null, medium);
+                        AddHandler(null, handler, null, medium, true);
                         return medium;
                     }
                     /// <summary>
                     /// Позволяет преобразовать результат выполения операции к новому типу.
                     /// </summary>
                     /// <typeparam name="TNew">Новый тип результата.</typeparam>
                     /// <param name="mapper">Преобразование результата к новому типу.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
                     /// <param name = "cancel"></param>
                     public IPromise<TNew> Then<TNew>(Func<T, TNew> mapper, Func<Exception,TNew> error, Action cancel) {
                         Safe.ArgumentNotNull(mapper, "mapper");
                         // создаем прицепленное обещание
                         var medium = new Promise<TNew>(this);
                         Action<T> resultHandler = result => medium.Resolve(mapper(result));
                         Func<Exception,T> errorHandler;
                         if (error != null)
                             errorHandler = e => {
                                 try {
                                     medium.Resolve(error(e));
                                 } catch (Exception e2) {
                                     // в случае ошибки нужно передать исключение дальше по цепочке
                                     medium.Reject(e2);
                                 }
                                 return default(T);
                             };
                         else
                             errorHandler = e => {
                                 medium.Reject(e);
                                 return default(T);
                             };
                         Action cancelHandler;
                         if (cancel != null)
                             cancelHandler = () => {
                                 cancel();
                                 medium.Cancel();
                             };
                         else
                             cancelHandler = medium.Cancel;
                         AddHandler(
                             resultHandler,
                             errorHandler,
                             cancelHandler,
-                            null
+                            null,
+                            true
                         );
                         return medium;
                     }
                     public IPromise<TNew> Then<TNew>(Func<T, TNew> mapper, Func<Exception,TNew> error) {
                         return Then(mapper, error, null);
                     }
                     public IPromise<TNew> Then<TNew>(Func<T, TNew> mapper) {
                         return Then(mapper, null, null);
                     }
                     /// <summary>
                     /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
                     /// выполнения текущей, а результат текущей операции может быть использован для инициализации
                     /// новой операции.
                     /// </summary>
                     /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
                     /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении текуещй операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
                     /// <param name = "cancel"></param>
                     public IPromise<TNew> Chain<TNew>(Func<T, IPromise<TNew>> chained, Func<Exception,IPromise<TNew>> error, Action cancel) {
                         Safe.ArgumentNotNull(chained, "chained");
                         // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
                         // создать посредника, к которому будут подвызяваться следующие обработчики.
                         // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
                         // передать через него результаты работы.
                         var medium = new Promise<TNew>(this);
                         Action<T> resultHandler = delegate(T result) {
                             if (medium.IsCancelled)
                                 return;
                             var promise = chained(result);
-                            promise.Last(
+                            promise.On(
                                 medium.Resolve,
                                 medium.Reject,
                                 () => medium.Reject(new OperationCanceledException()) // внешняя отмена связанной операции рассматривается как ошибка
                             );
                             // notify chained operation that it's not needed anymore
                             // порядок вызова Then, Cancelled важен, поскольку от этого
                             // зависит IsExclusive
-                            medium.Last(
+                            medium.On(
                                 null,
                                 null,
                                 () => {
                                     if (promise.IsExclusive)
                                         promise.Cancel();
                                 }
                             );
                         };
                         Func<Exception,T> errorHandler;
                         if (error != null)
                             errorHandler = delegate(Exception e) {
                                 try {
                                     var promise = error(e);
-                                    promise.Last(
+                                    promise.On(
                                         medium.Resolve,
                                         medium.Reject,
                                         () => medium.Reject(new OperationCanceledException()) // внешняя отмена связанной операции рассматривается как ошибка
                                     );
                                     // notify chained operation that it's not needed anymore
                                     // порядок вызова Then, Cancelled важен, поскольку от этого
                                     // зависит IsExclusive
                                     medium.Cancelled(() => {
                                         if (promise.IsExclusive)
                                             promise.Cancel();
                                     });
                                 } catch (Exception e2) {
                                     medium.Reject(e2);
                                 }
                                 return default(T);
                             };
                         else
                             errorHandler = err => {
                                 medium.Reject(err);
                                 return default(T);
                             };
                         Action cancelHandler;
                         if (cancel != null)
                             cancelHandler = () => {
                                 if (cancel != null)
                                     cancel();
                                 medium.Cancel();
                             };
                         else
                             cancelHandler = medium.Cancel;
                         AddHandler(
                             resultHandler,
                             errorHandler,
                             cancelHandler,
-                            null
+                            null,
+                            true
                         );
                         return medium;
                     }
                     public IPromise<TNew> Chain<TNew>(Func<T, IPromise<TNew>> chained, Func<Exception,IPromise<TNew>> error) {
                         return Chain(chained, error, null);
                     }
                     public IPromise<TNew> Chain<TNew>(Func<T, IPromise<TNew>> chained) {
                         return Chain(chained, null, null);
                     }
                     public IPromise<T> Cancelled(Action handler) {
                         var medium = new Promise<T>(this);
-                        AddHandler(null, null, handler, medium);
+                        AddHandler(null, null, handler, medium, false);
                         return medium;
                     }
                     /// <summary>
                     /// Adds the specified handler for all cases (success, error, cancel)
                     /// </summary>
                     /// <param name="handler">The handler that will be called anyway</param>
                     /// <returns>self</returns>
                     public IPromise<T> Anyway(Action handler) {
                         Safe.ArgumentNotNull(handler, "handler");
+                        var medium = new Promise<T>(this);
                         AddHandler(
                             x => handler(),
                             e => {
                                 handler();
                                 throw new TransientPromiseException(e);
                             },
                             handler,
-                            null
+                            medium,
+                            true
                         );
-                        return this;
+                        return medium;
                     }
                     /// <summary>
                     /// Преобразует результат обещания к нужному типу
                     /// </summary>
                     /// <typeparam name="T2"></typeparam>
                     /// <returns></returns>
                     public IPromise<T2> Cast<T2>() {
                         return Then(x => (T2)(object)x, null);
                     }
                     /// <summary>
                     /// Дожидается отложенного обещания и в случае успеха, возвращает
                     /// его, результат, в противном случае бросает исключение.
                     /// </summary>
                     /// <remarks>
                     /// <para>
                     /// Если ожидание обещания было прервано по таймауту, это не значит,
                     /// что обещание было отменено или что-то в этом роде, это только
                     /// означает, что мы его не дождались, однако все зарегистрированные
                     /// обработчики, как были так остались и они будут вызваны, когда
                     /// обещание будет выполнено.
                     /// </para>
                     /// <para>
                     /// Такое поведение вполне оправдано поскольку таймаут может истечь
                     /// в тот момент, когда началась обработка цепочки обработчиков, и
                     /// к тому же текущее обещание может стоять в цепочке обещаний и его
                     /// отклонение может привести к непрогнозируемому результату.
                     /// </para>
                     /// </remarks>
                     /// <param name="timeout">Время ожидания</param>
                     /// <returns>Результат выполнения обещания</returns>
                     public T Join(int timeout) {
                         var evt = new ManualResetEvent(false);
                         Anyway(() => evt.Set());
                         if (!evt.WaitOne(timeout, true))
                             throw new TimeoutException();
                         switch (m_state) {
                             case SUCCEEDED_STATE:
                                 return m_result;
                             case CANCELLED_STATE:
                                 throw new OperationCanceledException();
                             case REJECTED_STATE:
                                 throw new TargetInvocationException(m_error);
                             default:
                                 throw new ApplicationException(String.Format("Invalid promise state {0}", m_state));
                         }
                     }
                     public T Join() {
                         return Join(Timeout.Infinite);
                     }
-                    void AddHandler(Action<T> success, Func<Exception,T> error, Action cancel, Promise<T> medium) {
+                    void AddHandler(Action<T> success, Func<Exception,T> error, Action cancel, Promise<T> medium, bool inc) {
-                        if (success != null || error != null)
+                        if (inc)
                             Interlocked.Increment(ref m_childrenCount);
                         var handler = new HandlerDescriptor {
                             resultHandler = success,
                             errorHandler = error,
                             cancellHandler = cancel,
                             medium = medium
                         };
                         bool queued;
                         if (!IsResolved) {
                             m_handlers.Enqueue(handler);
                             queued = true;
                         } else {
                             // the promise is in resolved state, just invoke the handled with minimum overhead
                             queued = false;
                             InvokeHandler(handler);
                         }
                         if (queued && IsResolved && m_handlers.TryDequeue(out handler))
                             // if the promise have been resolved while we was adding handler to the queue
                             // we can't guarantee that someone is still processing it
                             // therefore we will fetch a handler from the queue and execute it
                             // note that fetched handler may be not the one that we have added
                             // even we can fetch no handlers at all :)
                             InvokeHandler(handler);
                     }
                     protected virtual void InvokeHandler(HandlerDescriptor handler) {
                         switch (m_state) {
                             case SUCCEEDED_STATE:
                                 handler.Resolve(m_result);
                                 break;
                             case REJECTED_STATE:
                                 handler.Reject(m_error);
                                 break;
                             case CANCELLED_STATE:
                                 handler.Cancel();
                                 break;
                             default:
                                 // do nothing
                                 return;
                         }
                     }
                     void OnStateChanged() {
                         HandlerDescriptor handler;
                         while (m_handlers.TryDequeue(out handler))
                             InvokeHandler(handler);
                     }
                     public bool IsExclusive {
                         get {
                             return m_childrenCount <= 1;
                         }
                     }
                     /// <summary>
                     /// Объединяет несколько обещаний в одно, результатом которого является массив результатов других обещаний.
                     /// Если хотябы одно из переданных обещаний не будет выполнено, то новое обещение тоже не будет выполнено.
                     /// При отмене нового обещания, переданные обещания также будут отменены, если никто больше на них не подписан.
                     /// </summary>
                     /// <param name="promises">Список обещаний. Если список пустой, то результирующее обещание возвращается уже выполненным.</param>
                     /// <returns>Обещание объединяющее в себе результат переданных обещаний.</returns>
                     /// <exception cref="ArgumentNullException"><paramref name="promises"/> не может быть null</exception>
                     public static IPromise<T[]> CreateComposite(IList<IPromise<T>> promises) {
                         if (promises == null)
                             throw new ArgumentNullException();
                         // создаем аккумулятор для результатов и результирующее обещание
                         var result = new T[promises.Count];
                         var promise = new Promise<T[]>();
                         // special case
                         if (promises.Count == 0) {
                             promise.Resolve(result);
                             return promise;
                         }
                         int pending = promises.Count;
                         for (int i = 0; i < promises.Count; i++) {
                             var dest = i;
                             if (promises[i] != null) {
                                 promises[i].Then(
                                     x => {
                                         result[dest] = x;
                                         if (Interlocked.Decrement(ref pending) == 0)
                                             promise.Resolve(result);
                                     },
                                     e => {
                                         promise.Reject(e);
                                         return default(T);
                                     }
                                 );
                             } else {
                                 if (Interlocked.Decrement(ref pending) == 0)
                                     promise.Resolve(result);
                             }
                         }
                         promise.Cancelled(
                             () => {
                                 foreach (var d in promises)
                                     if (d != null && d.IsExclusive)
                                         d.Cancel();
                             }
                         );
                         return promise;
                     }
                     /// <summary>
                     /// Объединяет несколько обещаний в одно. Результирующее обещание будет выполнено при
                     /// выполнении всех указанных обещаний. При этом возвращаемые значения первичных обещаний
                     /// игнорируются.
                     /// </summary>
                     /// <param name="promises">Коллекция первичных обещаний, которые будут объеденены в одно.</param>
                     /// <returns>Новое обещание, объединяющее в себе переданные.</returns>
                     /// <remarks>
                     /// Если в коллекции встречаюься <c>null</c>, то они воспринимаются как выполненные обещания.
                     /// </remarks>
                     public static IPromise CreateComposite(ICollection<IPromise> promises) {
                         if (promises == null)
                             throw new ArgumentNullException();
                         if (promises.Count == 0)
                             return Promise<object>.ResultToPromise(null);
                         int countdown = promises.Count;
                         var result = new Promise<object>();
                         foreach (var d in promises) {
                             if (d == null) {
                                 if (Interlocked.Decrement(ref countdown) == 0)
                                     result.Resolve(null);
                             } else {
                                 d.Then(() => {
                                     if (Interlocked.Decrement(ref countdown) == 0)
                                         result.Resolve(null);
                                 });
                             }
                         }
                         result.Cancelled(() => {
                             foreach (var d in promises)
                                 if (d != null && d.IsExclusive)
                                     d.Cancel();
                         });
                         return result;
                     }
                     public static Promise<T> ResultToPromise(T result) {
                         var p = new Promise<T>();
                         p.Resolve(result);
                         return p;
                     }
                     public static Promise<T> ExceptionToPromise(Exception error) {
                         if (error == null)
                             throw new ArgumentNullException();
                         var p = new Promise<T>();
                         p.Reject(error);
                         return p;
                     }
                     #region IPromiseBase explicit implementation
                     IPromise IPromise.Then(Action success, Action<Exception> error, Action cancel) {
                         return Then(
                             success != null ? new Action<T>(x => success()) : null,
                             error != null ? new Func<Exception,T>(e => {
                                 error(e);
                                 return default(T);
                             }) : null,
                             cancel
                         );
                     }
                     IPromise IPromise.Then(Action success, Action<Exception> error) {
                         return Then(
                             success != null ? new Action<T>(x => success()) : null,
                             error != null ? new Func<Exception,T>(e => {
                                 error(e);
                                 return default(T);
                             }) : null
                         );
                     }
                     IPromise IPromise.Then(Action success) {
                         Safe.ArgumentNotNull(success, "success");
                         return Then(x => success());
                     }
                     IPromise IPromise.Chain(Func<IPromise> chained, Func<Exception,IPromise> error, Action cancel) {
                         return ChainNoResult(chained, error, cancel);
                     }
                     IPromise ChainNoResult(Func<IPromise> chained, Func<Exception,IPromise> error, Action cancel) {
-                            Safe.ArgumentNotNull(chained, "chained");
+                        Safe.ArgumentNotNull(chained, "chained");
                         var medium = new Promise<object>(this);
                         Action<T> resultHandler = delegate {
-                                if (medium.IsCancelled)
+                            if (medium.IsCancelled)
-                                    return;
+                                return;
-                                var promise = chained();
+                            var promise = chained();
-                                promise.Last(
+                            promise.On(
-                                    medium.Resolve,
+                                medium.Resolve,
-                                    medium.Reject,
+                                medium.Reject,
-                                    () => medium.Reject(new OperationCanceledException()) // внешняя отмена связанной операции рассматривается как ошибка
+                                () => medium.Reject(new OperationCanceledException()) // внешняя отмена связанной операции рассматривается как ошибка
-                                );
+                            );
-                                // notify chained operation that it's not needed anymore
+                            // notify chained operation that it's not needed anymore
-                                // порядок вызова Then, Cancelled важен, поскольку от этого
+                            // порядок вызова Then, Cancelled важен, поскольку от этого
-                                // зависит IsExclusive
+                            // зависит IsExclusive
-                                medium.Cancelled(() => {
+                            medium.Cancelled(() => {
-                                    if (promise.IsExclusive)
+                                if (promise.IsExclusive)
-                                        promise.Cancel();
+                                    promise.Cancel();
-                                });
+                            });
-                            };
+                        };
                         Func<Exception,T> errorHandler;
-                            if (error != null)
+                        if (error != null)
-                                errorHandler = delegate(Exception e) {
+                            errorHandler = delegate(Exception e) {
                                 try {
                                     var promise = error(e);
-                                    promise.Last(
+                                    promise.On(
                                         medium.Resolve,
                                         medium.Reject,
                                         () => medium.Reject(new OperationCanceledException()) // внешняя отмена связанной операции рассматривается как ошибка
                                     );
                                     // notify chained operation that it's not needed anymore
                                     // порядок вызова Then, Cancelled важен, поскольку от этого
                                     // зависит IsExclusive
                                     medium.Cancelled(() => {
                                         if (promise.IsExclusive)
                                             promise.Cancel();
                                     });
                                 } catch (Exception e2) {
                                     medium.Reject(e2);
                                 }
                                 return default(T);
                             };
-                            else
+                        else
-                                errorHandler = err => {
+                            errorHandler = err => {
                                 medium.Reject(err);
                                 return default(T);
                             };
-                            Action cancelHandler;
+                        Action cancelHandler;
-                            if (cancel != null)
+                        if (cancel != null)
-                                cancelHandler = () => {
+                            cancelHandler = () => {
                                 if (cancel != null)
                                     cancel();
                                 medium.Cancel();
                             };
-                            else
+                        else
-                                cancelHandler = medium.Cancel;
+                            cancelHandler = medium.Cancel;
-                            AddHandler(
+                        AddHandler(
-                                resultHandler,
+                            resultHandler,
-                                errorHandler,
+                            errorHandler,
-                                cancelHandler,
+                            cancelHandler,
-                                null
+                            null,
-                            );
+                            true
+                        );
-                            return medium;
+                        return medium;
                     }
                     IPromise IPromise.Chain(Func<IPromise> chained, Func<Exception,IPromise> error) {
                         return ChainNoResult(chained, error, null);
                     }
                     IPromise IPromise.Chain(Func<IPromise> chained) {
                         return ChainNoResult(chained, null, null);
+                    }
-                    void IPromise.Last(Action success, Action<Exception> error, Action cancel) {
+                    void IPromise.On(Action success, Action<Exception> error, Action cancel) {
-                        Last(x => success(), error, cancel);
+                        On(x => success(), error, cancel);
                     }
-                    void IPromise.Last(Action success, Action<Exception> error) {
+                    void IPromise.On(Action success, Action<Exception> error) {
-                        Last(x => success(), error, null);
+                        On(x => success(), error, null);
                     }
-                    void IPromise.Last(Action success) {
+                    void IPromise.On(Action success) {
-                        Last(x => success(), null, null);
+                        On(x => success(), null, null);
                     }
                     IPromise IPromise.Error(Action<Exception> error) {
                         return Error(error);
                     }
                     IPromise IPromise.Anyway(Action handler) {
                         return Anyway(handler);
                     }
                     IPromise IPromise.Cancelled(Action handler) {
                         return Cancelled(handler);
                     }
                     void IPromise.Join() {
                         Join();
                     }
                     void IPromise.Join(int timeout) {
                         Join(timeout);
                     }
                     #endregion
                 }
             }

Implab/PromiseExtensions.cs +4 -4

             using System.Threading;
             using System;
             #if NET_4_5
             using System.Threading.Tasks;
             #endif
             namespace Implab {
                 public static class PromiseExtensions {
                     public static IPromise<T> DispatchToCurrentContext<T>(this IPromise<T> that) {
                         Safe.ArgumentNotNull(that, "that");
                         var context = SynchronizationContext.Current;
                         if (context == null)
                             return that;
                         var p = new SyncContextPromise<T>(context, that);
-                        that.Last(
+                        that.On(
                             p.Resolve,
                             p.Reject,
                             p.Cancel
                         );
                         return p;
                     }
                     public static IPromise<T> DispatchToContext<T>(this IPromise<T> that, SynchronizationContext context) {
                         Safe.ArgumentNotNull(that, "that");
                         Safe.ArgumentNotNull(context, "context");
                         var p = new SyncContextPromise<T>(context, that);
-                        that.Last(
+                        that.On(
                             p.Resolve,
                             p.Reject,
                             p.Cancel
                         );
                         return p;
                     }
                     /// <summary>
                     /// Ensures the dispatched.
                     /// </summary>
                     /// <returns>The dispatched.</returns>
                     /// <param name="that">That.</param>
                     /// <param name="head">Head.</param>
                     /// <param name="cleanup">Cleanup.</param>
                     /// <typeparam name="TPromise">The 1st type parameter.</typeparam>
                     /// <typeparam name="T">The 2nd type parameter.</typeparam>
                     public static TPromise EnsureDispatched<TPromise,T>(this TPromise that, IPromise<T> head, Action<T> cleanup) where TPromise : IPromise{
                         Safe.ArgumentNotNull(that, "that");
                         Safe.ArgumentNotNull(head, "head");
-                        that.Last(null,null,() => head.Last(cleanup));
+                        that.On(null,null,() => head.On(cleanup));
                         return that;
                     }
                     public static AsyncCallback AsyncCallback<T>(this Promise<T> that, Func<IAsyncResult,T> callback) {
                         Safe.ArgumentNotNull(that, "that");
                         Safe.ArgumentNotNull(callback, "callback");
                         return ar => {
                             try {
                                 that.Resolve(callback(ar));
                             } catch (Exception err) {
                                 that.Reject(err);
                             }
                         };
                     }
                     #if NET_4_5
                     public static Task<T> GetTask<T>(this IPromise<T> that) {
                         Safe.ArgumentNotNull(that, "that");
                         var tcs = new TaskCompletionSource<T>();
-                        that.Last(tcs.SetResult, tcs.SetException, tcs.SetCanceled);
+                        that.On(tcs.SetResult, tcs.SetException, tcs.SetCanceled);
                         return tcs.Task;
                     }
                     #endif
                 }
             }

MonoPlay/Program.cs +2 -2

             using System;
             using Implab.Diagnostics;
             using Implab.Parallels;
             using Implab;
             using System.Collections.Generic;
             using System.Collections.Concurrent;
             namespace MonoPlay {
                 class MainClass {
                     public static void Main(string[] args) {
                         if (args == null)
                             throw new ArgumentNullException("args");
                         var q1 = new MTQueue<int>();
-                        var q2 = new ConcurrentQueue<int>();
+                        var q2 = new Queue<int>();
                         const int count = 10000000;
                         var t1 = Environment.TickCount;
                         for (var i = 0; i < count; i++)
                             q1.Enqueue(i);
                         var t2 = Environment.TickCount;
                         Console.WriteLine("MTQueue: {0} ms", t2 - t1);
                         t1 = Environment.TickCount;
                         for (var i = 0; i < count; i++)
                             q2.Enqueue(i);
                         t2 = Environment.TickCount;
                         Console.WriteLine("LinkedList: {0} ms", t2 - t1);
-                        q2 = new ConcurrentQueue<int>();
+                        q2 = new Queue<int>();
                         t1 = Environment.TickCount;
                         for (var i = 0; i < count; i++)
                             lock (q2)
                                 q2.Enqueue(i);
                         t2 = Environment.TickCount;
                         Console.WriteLine("LinkedList+Lock: {0} ms", t2 - t1);
                     }
                 }
             }

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	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