##// END OF EJS Templates
initial commit...
user@factory.site.local -
r0:279591fb4df3 default
parent child
Show More
@@ -0,0 +1,8
1 syntax: glob
2 Implab.Test/bin/
3 *.user
4 Implab.Test/obj/
5 *.userprefs
6 Implab/bin/
7 Implab/obj/
8 TestResults/
@@ -0,0 +1,101
1 using System;
2 using Microsoft.VisualStudio.TestTools.UnitTesting;
3 using Implab;
4 using System.Reflection;
5 using System.Threading;
6
7 namespace Implab.Tests
8 {
9 [TestClass]
10 public class AsyncTests
11 {
12 [TestMethod]
13 public void ResolveTest ()
14 {
15 int res = -1;
16 var p = new Promise<int> ();
17 p.Then (x => res = x);
18 p.Resolve (100);
19
20 Assert.AreEqual (res, 100);
21 }
22
23 [TestMethod]
24 public void RejectTest ()
25 {
26 int res = -1;
27 Exception err = null;
28
29 var p = new Promise<int> ();
30 p.Then (x => res = x, e => err = e);
31 p.Reject (new ApplicationException ("error"));
32
33 Assert.AreEqual (res, -1);
34 Assert.AreEqual (err.Message, "error");
35
36 }
37
38 [TestMethod]
39 public void JoinSuccessTest ()
40 {
41 var p = new Promise<int> ();
42 p.Resolve (100);
43 Assert.AreEqual (p.Join (), 100);
44 }
45
46 [TestMethod]
47 public void JoinFailTest ()
48 {
49 var p = new Promise<int> ();
50 p.Reject (new ApplicationException ("failed"));
51
52 try {
53 p.Join ();
54 throw new ApplicationException ("WRONG!");
55 } catch (TargetInvocationException err) {
56 Assert.AreEqual (err.InnerException.Message, "failed");
57 } catch {
58 Assert.Fail ("Got wrong excaption");
59 }
60 }
61
62 [TestMethod]
63 public void MapTest ()
64 {
65 var p = new Promise<int> ();
66
67 var p2 = p.Map (x => x.ToString ());
68 p.Resolve (100);
69
70 Assert.AreEqual (p2.Join (), "100");
71 }
72
73 [TestMethod]
74 public void ChainTest ()
75 {
76 var p1 = new Promise<int> ();
77
78 var p3 = p1.Chain (x => {
79 var p2 = new Promise<string> ();
80 p2.Resolve (x.ToString ());
81 return p2;
82 });
83
84 p1.Resolve (100);
85
86 Assert.AreEqual (p3.Join (), "100");
87 }
88
89 [TestMethod]
90 public void PoolTest ()
91 {
92 var pid = Thread.CurrentThread.ManagedThreadId;
93 var p = AsyncPool.Invoke (() => {
94 return Thread.CurrentThread.ManagedThreadId;
95 });
96
97 Assert.AreNotEqual (pid, p.Join ());
98 }
99 }
100 }
101
@@ -0,0 +1,65
1 <?xml version="1.0" encoding="utf-8"?>
2 <Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
3 <PropertyGroup>
4 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
5 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
6 <ProductVersion>
7 </ProductVersion>
8 <SchemaVersion>2.0</SchemaVersion>
9 <ProjectGuid>{63F92C0C-61BF-48C0-A377-8D67C3C661D0}</ProjectGuid>
10 <OutputType>Library</OutputType>
11 <AppDesignerFolder>Properties</AppDesignerFolder>
12 <RootNamespace>Implab.Test</RootNamespace>
13 <AssemblyName>Implab.Test</AssemblyName>
14 <TargetFrameworkVersion>v4.0</TargetFrameworkVersion>
15 <FileAlignment>512</FileAlignment>
16 <ProjectTypeGuids>{3AC096D0-A1C2-E12C-1390-A8335801FDAB};{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}</ProjectTypeGuids>
17 </PropertyGroup>
18 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
19 <DebugSymbols>true</DebugSymbols>
20 <DebugType>full</DebugType>
21 <Optimize>false</Optimize>
22 <OutputPath>bin\Debug\</OutputPath>
23 <DefineConstants>DEBUG;TRACE</DefineConstants>
24 <ErrorReport>prompt</ErrorReport>
25 <WarningLevel>4</WarningLevel>
26 </PropertyGroup>
27 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
28 <DebugType>pdbonly</DebugType>
29 <Optimize>true</Optimize>
30 <OutputPath>bin\Release\</OutputPath>
31 <DefineConstants>TRACE</DefineConstants>
32 <ErrorReport>prompt</ErrorReport>
33 <WarningLevel>4</WarningLevel>
34 </PropertyGroup>
35 <ItemGroup>
36 <Reference Include="Microsoft.VisualStudio.QualityTools.UnitTestFramework, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL" />
37 <Reference Include="System" />
38 <Reference Include="System.Core">
39 <RequiredTargetFramework>3.5</RequiredTargetFramework>
40 </Reference>
41 </ItemGroup>
42 <ItemGroup>
43 <CodeAnalysisDependentAssemblyPaths Condition=" '$(VS100COMNTOOLS)' != '' " Include="$(VS100COMNTOOLS)..\IDE\PrivateAssemblies">
44 <Visible>False</Visible>
45 </CodeAnalysisDependentAssemblyPaths>
46 </ItemGroup>
47 <ItemGroup>
48 <Compile Include="AsyncTests.cs" />
49 <Compile Include="Properties\AssemblyInfo.cs" />
50 </ItemGroup>
51 <ItemGroup>
52 <ProjectReference Include="..\Implab\Implab.csproj">
53 <Project>{99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}</Project>
54 <Name>Implab</Name>
55 </ProjectReference>
56 </ItemGroup>
57 <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
58 <!-- To modify your build process, add your task inside one of the targets below and uncomment it.
59 Other similar extension points exist, see Microsoft.Common.targets.
60 <Target Name="BeforeBuild">
61 </Target>
62 <Target Name="AfterBuild">
63 </Target>
64 -->
65 </Project> No newline at end of file
@@ -0,0 +1,35
1 using System.Reflection;
2 using System.Runtime.CompilerServices;
3 using System.Runtime.InteropServices;
4
5 // General Information about an assembly is controlled through the following
6 // set of attributes. Change these attribute values to modify the information
7 // associated with an assembly.
8 [assembly: AssemblyTitle("Implab.Test")]
9 [assembly: AssemblyDescription("")]
10 [assembly: AssemblyConfiguration("")]
11 [assembly: AssemblyCompany("")]
12 [assembly: AssemblyProduct("Implab.Test")]
13 [assembly: AssemblyCopyright("Copyright © 2013")]
14 [assembly: AssemblyTrademark("")]
15 [assembly: AssemblyCulture("")]
16
17 // Setting ComVisible to false makes the types in this assembly not visible
18 // to COM components. If you need to access a type in this assembly from
19 // COM, set the ComVisible attribute to true on that type.
20 [assembly: ComVisible(false)]
21
22 // The following GUID is for the ID of the typelib if this project is exposed to COM
23 [assembly: Guid("bfcae720-21eb-4411-b70a-6eeab99071de")]
24
25 // Version information for an assembly consists of the following four values:
26 //
27 // Major Version
28 // Minor Version
29 // Build Number
30 // Revision
31 //
32 // You can specify all the values or you can default the Build and Revision Numbers
33 // by using the '*' as shown below:
34 [assembly: AssemblyVersion("1.0.0.0")]
35 [assembly: AssemblyFileVersion("1.0.0.0")]
@@ -0,0 +1,39
1 
2 Microsoft Visual Studio Solution File, Format Version 11.00
3 # Visual Studio 2010
4 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab", "Implab\Implab.csproj", "{99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}"
5 EndProject
6 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{CE8D8D18-437A-445C-B662-4C2CE79A76F6}"
7 ProjectSection(SolutionItems) = preProject
8 Implab.vsmdi = Implab.vsmdi
9 Local.testsettings = Local.testsettings
10 TraceAndTestImpact.testsettings = TraceAndTestImpact.testsettings
11 EndProjectSection
12 EndProject
13 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Test", "Implab.Test\Implab.Test.csproj", "{63F92C0C-61BF-48C0-A377-8D67C3C661D0}"
14 EndProject
15 Global
16 GlobalSection(TestCaseManagementSettings) = postSolution
17 CategoryFile = Implab.vsmdi
18 EndGlobalSection
19 GlobalSection(SolutionConfigurationPlatforms) = preSolution
20 Debug|Any CPU = Debug|Any CPU
21 Release|Any CPU = Release|Any CPU
22 EndGlobalSection
23 GlobalSection(ProjectConfigurationPlatforms) = postSolution
24 {99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
25 {99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}.Debug|Any CPU.Build.0 = Debug|Any CPU
26 {99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}.Release|Any CPU.ActiveCfg = Release|Any CPU
27 {99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}.Release|Any CPU.Build.0 = Release|Any CPU
28 {63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
29 {63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug|Any CPU.Build.0 = Debug|Any CPU
30 {63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release|Any CPU.ActiveCfg = Release|Any CPU
31 {63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release|Any CPU.Build.0 = Release|Any CPU
32 EndGlobalSection
33 GlobalSection(SolutionProperties) = preSolution
34 HideSolutionNode = FALSE
35 EndGlobalSection
36 GlobalSection(MonoDevelopProperties) = preSolution
37 StartupItem = Implab\Implab.csproj
38 EndGlobalSection
39 EndGlobal
1 NO CONTENT: new file 100644, binary diff hidden
NO CONTENT: new file 100644, binary diff hidden
@@ -0,0 +1,6
1 <?xml version="1.0" encoding="UTF-8"?>
2 <TestLists xmlns="http://microsoft.com/schemas/VisualStudio/TeamTest/2010">
3 <TestList name="Lists of Tests" id="8c43106b-9dc1-4907-a29f-aa66a61bf5b6">
4 <RunConfiguration id="adaa4751-cfb4-4c5f-85cb-0f017ce09812" name="Local" storage="local.testsettings" type="Microsoft.VisualStudio.TestTools.Common.TestRunConfiguration, Microsoft.VisualStudio.QualityTools.Common, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" />
5 </TestList>
6 </TestLists> No newline at end of file
@@ -0,0 +1,28
1 using System;
2 using System.Threading;
3
4 namespace Implab {
5 /// <summary>
6 /// Класс для распаралеливания задач.
7 /// </summary>
8 /// <remarks>
9 /// Используя данный класс и лямда выражения можно распараллелить
10 /// вычисления, для этого используется концепция обещаний.
11 /// </remarks>
12 public static class AsyncPool {
13
14 public static Promise<T> Invoke<T>(Func<T> func) {
15 var p = new Promise<T>();
16
17 ThreadPool.QueueUserWorkItem(param => {
18 try {
19 p.Resolve(func());
20 } catch(Exception e) {
21 p.Reject(e);
22 }
23 });
24
25 return p;
26 }
27 }
28 }
@@ -0,0 +1,43
1 <?xml version="1.0" encoding="utf-8"?>
2 <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
3 <PropertyGroup>
4 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
5 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
6 <ProductVersion>10.0.0</ProductVersion>
7 <SchemaVersion>2.0</SchemaVersion>
8 <ProjectGuid>{99B95D0D-9CF9-4F70-8ADF-F4D0AA5CB0D9}</ProjectGuid>
9 <OutputType>Library</OutputType>
10 <RootNamespace>Implab</RootNamespace>
11 <AssemblyName>Implab</AssemblyName>
12 </PropertyGroup>
13 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
14 <DebugSymbols>true</DebugSymbols>
15 <DebugType>full</DebugType>
16 <Optimize>false</Optimize>
17 <OutputPath>bin\Debug</OutputPath>
18 <DefineConstants>DEBUG;</DefineConstants>
19 <ErrorReport>prompt</ErrorReport>
20 <WarningLevel>4</WarningLevel>
21 <ConsolePause>false</ConsolePause>
22 </PropertyGroup>
23 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
24 <DebugType>full</DebugType>
25 <Optimize>true</Optimize>
26 <OutputPath>bin\Release</OutputPath>
27 <ErrorReport>prompt</ErrorReport>
28 <WarningLevel>4</WarningLevel>
29 <ConsolePause>false</ConsolePause>
30 </PropertyGroup>
31 <ItemGroup>
32 <Reference Include="System" />
33 </ItemGroup>
34 <ItemGroup>
35 <Compile Include="Properties\AssemblyInfo.cs" />
36 <Compile Include="Promise.cs" />
37 <Compile Include="AsyncPool.cs" />
38 </ItemGroup>
39 <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
40 <ItemGroup>
41 <Folder Include="Parallels\" />
42 </ItemGroup>
43 </Project> No newline at end of file
@@ -0,0 +1,350
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Reflection;
5 using System.Text;
6 using System.Diagnostics;
7 using System.Threading;
8
9 namespace Implab {
10
11 public delegate void ErrorHandler(Exception e);
12
13 public delegate void ResultHandler<T>(T result);
14 public delegate TNew ResultMapper<TSrc,TNew>(TSrc result);
15 public delegate Promise<TNew> ChainedOperation<TSrc,TNew>(TSrc result);
16
17 /// <summary>
18 /// Класс для асинхронного получения результатов. Так называемое "обещание".
19 /// </summary>
20 /// <typeparam name="T">Тип получаемого результата</typeparam>
21 /// <remarks>
22 /// <para>Сервис при обращении к его методу дает обещаиние о выполнении операции,
23 /// клиент получив такое обещание может установить ряд обратных вызово для получения
24 /// событий выполнения обещания, тоесть завершения операции и предоставлении результатов.</para>
25 /// <para>
26 /// Обещение может быть как выполнено, так и выполнено с ошибкой. Для подписки на
27 /// данные события клиент должен использовать методы <c>Then</c>.
28 /// </para>
29 /// <para>
30 /// Сервис, в свою очередь, по окончанию выполнения операции (возможно с ошибкой),
31 /// использует методы <c>Resolve</c> либо <c>Reject</c> для оповещения клиетна о
32 /// выполнении обещания.
33 /// </para>
34 /// <para>
35 /// Если сервер успел выполнить обещание еще до того, как клиент на него подписался,
36 /// то в момент подписки клиента будут вызваны соответсвующие события в синхронном
37 /// режиме и клиент будет оповещен в любом случае. Иначе, обработчики добавляются в
38 /// список в порядке подписания и в этом же порядке они будут вызваны при выполнении
39 /// обещания.
40 /// </para>
41 /// <para>
42 /// Обрабатывая результаты обещания можно преобразовывать результаты либо инициировать
43 /// связанные асинхронные операции, которые также возвращают обещания. Для этого следует
44 /// использовать соответствующую форму методе <c>Then</c>.
45 /// </para>
46 /// <para>
47 /// Также хорошим правилом является то, что <c>Resolve</c> и <c>Reject</c> должен вызывать
48 /// только инициатор обещания иначе могут возникнуть противоречия.
49 /// </para>
50 /// </remarks>
51 public class Promise<T> {
52
53 struct ResultHandlerInfo {
54 public ResultHandler<T> resultHandler;
55 public ErrorHandler errorHandler;
56 }
57
58 enum State {
59 Unresolved,
60 Resolving,
61 Resolved,
62 Cancelled
63 }
64
65 LinkedList<ResultHandlerInfo> m_handlersChain = new LinkedList<ResultHandlerInfo>();
66 State m_state;
67 bool m_cancellable;
68 T m_result;
69 Exception m_error;
70
71 public Promise() {
72 m_cancellable = true;
73 }
74
75 /// <summary>
76 /// Событие, возникающее при отмене асинхронной операции.
77 /// </summary>
78 /// <description>
79 /// Как правило используется для оповещения объекта, выполняющего асинхронную операцию, о том, что ее следует отменить.
80 /// </description>
81 public event EventHandler Cancelled;
82
83 /// <summary>
84 /// Выполняет обещание, сообщая об успешном выполнении.
85 /// </summary>
86 /// <param name="result">Результат выполнения.</param>
87 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
88 public void Resolve(T result) {
89 lock (this) {
90 if (m_state == State.Cancelled)
91 return;
92 if (m_state != State.Unresolved)
93 throw new InvalidOperationException("The promise is already resolved");
94 m_result = result;
95 m_state = State.Resolving;
96 }
97
98 ResultHandlerInfo handler;
99 while (FetchNextHandler(out handler))
100 InvokeHandler(handler);
101 }
102
103 /// <summary>
104 /// Выполняет обещание, сообщая об ошибке
105 /// </summary>
106 /// <param name="error">Исключение возникшее при выполнении операции</param>
107 /// <exception cref="InvalidOperationException">Данное обещание уже выполнено</exception>
108 public void Reject(Exception error) {
109 lock (this) {
110 if (m_state == State.Cancelled)
111 return;
112 if (m_state != State.Unresolved)
113 throw new InvalidOperationException("The promise is already resolved");
114 m_error = error;
115 m_state = State.Resolving;
116 }
117
118 ResultHandlerInfo handler;
119 while (FetchNextHandler(out handler))
120 InvokeHandler(handler);
121 }
122
123 /// <summary>
124 /// Отменяет операцию, если это возможно.
125 /// </summary>
126 /// <returns><c>true</c> Операция была отменена, обработчики не будут вызваны.<c>false</c> отмена не возможна, поскольку обещание уже выполнено и обработчики отработали.</returns>
127 public bool Cancel() {
128 lock(this) {
129 if (m_state == State.Unresolved && m_cancellable) {
130 m_state = State.Cancelled;
131 return true;
132 } else
133 return false;
134 }
135 }
136
137 /// <summary>
138 /// Добавляет обработчики событий выполнения обещания.
139 /// </summary>
140 /// <param name="success">Обработчик успешного выполнения обещания.
141 /// Данному обработчику будет передан результат выполнения операции.</param>
142 /// <param name="error">Обработчик ошибки. Данный обработчик получит
143 /// исключение возникшее при выполнении операции.</param>
144 /// <returns>Само обещание</returns>
145 public Promise<T> Then(ResultHandler<T> success, ErrorHandler error) {
146 if (success == null && error == null)
147 return this;
148
149 AddHandler(new ResultHandlerInfo() {
150 resultHandler = success,
151 errorHandler = error
152 });
153
154 return this;
155 }
156
157 public Promise<T> Then(ResultHandler<T> success) {
158 return Then (success, null);
159 }
160
161 public Promise<T> Anyway(Action handler) {
162 if (handler == null)
163 return this;
164 AddHandler(new ResultHandlerInfo {
165 resultHandler = x => handler(),
166 errorHandler = x => handler()
167 });
168
169 return this;
170 }
171
172 /// <summary>
173 /// Позволяет преобразовать результат выполения операции к новому типу.
174 /// </summary>
175 /// <typeparam name="TNew">Новый тип результата.</typeparam>
176 /// <param name="mapper">Преобразование результата к новому типу.</param>
177 /// <param name="error">Обработчик ошибки. Данный обработчик получит
178 /// исключение возникшее при выполнении операции.</param>
179 /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
180 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler error) {
181 if (mapper == null)
182 throw new ArgumentNullException("mapper");
183
184 // создаем прицепленное обещание
185 Promise<TNew> chained = new Promise<TNew>();
186
187 AddHandler(new ResultHandlerInfo() {
188 resultHandler = delegate(T result) {
189 try {
190 // если преобразование выдаст исключение, то сработает reject сцепленного deferred
191 chained.Resolve(mapper(result));
192 } catch (Exception e) {
193 chained.Reject(e);
194 }
195 },
196 errorHandler = delegate(Exception e) {
197 if (error != null)
198 error(e);
199 // в случае ошибки нужно передать исключение дальше по цепочке
200 chained.Reject(e);
201 }
202 });
203
204 return chained;
205 }
206
207 public Promise<TNew> Map<TNew>(ResultMapper<T, TNew> mapper) {
208 return Map (mapper, null);
209 }
210
211 /// <summary>
212 /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
213 /// выполнения текущей, а результат текущей операции может быть использован для инициализации
214 /// новой операции.
215 /// </summary>
216 /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
217 /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
218 /// <param name="error">Обработчик ошибки. Данный обработчик получит
219 /// исключение возникшее при выполнении текуещй операции.</param>
220 /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
221 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained, ErrorHandler error) {
222
223 // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
224 // создать посредника, к которому будут подвызяваться следующие обработчики.
225 // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
226 // передать через него результаты работы.
227 Promise<TNew> medium = new Promise<TNew>();
228
229 AddHandler(new ResultHandlerInfo() {
230 resultHandler = delegate(T result) {
231 try {
232 chained(result).Then(
233 x => medium.Resolve(x),
234 e => medium.Reject(e)
235 );
236 } catch(Exception e) {
237 // если сцепленное действие выдало исключение вместо обещания, то передаем ошибку по цепочке
238 medium.Reject(e);
239 }
240 },
241 errorHandler = delegate(Exception e) {
242 if (error != null)
243 error(e);
244 // в случае ошибки нужно передать исключение дальше по цепочке
245 medium.Reject(e);
246 }
247 });
248
249 return medium;
250 }
251
252 public Promise<TNew> Chain<TNew>(ChainedOperation<T, TNew> chained) {
253 return Chain (chained, null);
254 }
255
256 /// <summary>
257 /// Дожидается отложенного обещания и в случае успеха, возвращает
258 /// его, результат, в противном случае бросает исключение.
259 /// </summary>
260 /// <remarks>
261 /// <para>
262 /// Если ожидание обещания было прервано по таймауту, это не значит,
263 /// что обещание было отменено или что-то в этом роде, это только
264 /// означает, что мы его не дождались, однако все зарегистрированные
265 /// обработчики, как были так остались и они будут вызваны, когда
266 /// обещание будет выполнено.
267 /// </para>
268 /// <para>
269 /// Такое поведение вполне оправдано поскольку таймаут может истечь
270 /// в тот момент, когда началась обработка цепочки обработчиков, и
271 /// к тому же текущее обещание может стоять в цепочке обещаний и его
272 /// отклонение может привести к непрогнозируемому результату.
273 /// </para>
274 /// </remarks>
275 /// <param name="timeout">Время ожидания</param>
276 /// <returns>Результат выполнения обещания</returns>
277 public T Join(int timeout) {
278 ManualResetEvent evt = new ManualResetEvent(false);
279 Anyway(() => evt.Set());
280
281 if (!evt.WaitOne(timeout, true))
282 throw new TimeoutException();
283
284 if (m_error != null)
285 throw new TargetInvocationException( m_error );
286 else
287 return m_result;
288 }
289
290 public T Join() {
291 return Join(Timeout.Infinite);
292 }
293
294 /// <summary>
295 /// Данный метод последовательно извлекает обработчики обещания и когда
296 /// их больше не осталось - ставит состояние "разрешено".
297 /// </summary>
298 /// <param name="handler">Информация об обработчике</param>
299 /// <returns>Признак того, что еще остались обработчики в очереди</returns>
300 bool FetchNextHandler(out ResultHandlerInfo handler) {
301 handler = default(ResultHandlerInfo);
302
303 lock (this) {
304 Debug.Assert(m_state == State.Resolving);
305
306 if (m_handlersChain.Count > 0) {
307 handler = m_handlersChain.First.Value;
308 m_handlersChain.RemoveFirst();
309 return true;
310 } else {
311 m_state = State.Resolved;
312 return false;
313 }
314 }
315 }
316
317 void AddHandler(ResultHandlerInfo handler) {
318 bool invokeRequired = false;
319
320 lock (this) {
321 if (m_state != State.Resolved)
322 m_handlersChain.AddLast(handler);
323 else
324 invokeRequired = true;
325 }
326
327 // обработчики не должны блокировать сам объект
328 if (invokeRequired)
329 InvokeHandler(handler);
330 }
331
332 void InvokeHandler(ResultHandlerInfo handler) {
333 if (m_error == null) {
334 try {
335 if (handler.resultHandler != null)
336 handler.resultHandler(m_result);
337 } catch { }
338 }
339
340 if (m_error != null) {
341 try {
342 if (handler.errorHandler !=null)
343 handler.errorHandler(m_error);
344 } catch { }
345 }
346 }
347
348
349 }
350 }
@@ -0,0 +1,25
1 using System.Reflection;
2 using System.Runtime.CompilerServices;
3
4 // Information about this assembly is defined by the following attributes.
5 // Change them to the values specific to your project.
6
7 [assembly: AssemblyTitle("Implab")]
8 [assembly: AssemblyDescription("Tools")]
9 [assembly: AssemblyConfiguration("")]
10 [assembly: AssemblyCompany("")]
11 [assembly: AssemblyProduct("")]
12 [assembly: AssemblyCopyright("Implab")]
13 [assembly: AssemblyTrademark("")]
14 // The assembly version has the format "{Major}.{Minor}.{Build}.{Revision}".
15 // The form "{Major}.{Minor}.*" will automatically update the build and revision,
16 // and "{Major}.{Minor}.{Build}.*" will update just the revision.
17
18 [assembly: AssemblyVersion("1.0.*")]
19
20 // The following attributes are used to specify the signing key for the assembly,
21 // if desired. See the Mono documentation for more information about signing.
22
23 //[assembly: AssemblyDelaySign(false)]
24 //[assembly: AssemblyKeyFile("")]
25
@@ -0,0 +1,10
1 <?xml version="1.0" encoding="UTF-8"?>
2 <TestSettings name="Local" id="adaa4751-cfb4-4c5f-85cb-0f017ce09812" xmlns="http://microsoft.com/schemas/VisualStudio/TeamTest/2010">
3 <Description>These are default test settings for a local test run.</Description>
4 <Deployment enabled="false" />
5 <Execution>
6 <TestTypeSpecific />
7 <AgentRule name="Execution Agents">
8 </AgentRule>
9 </Execution>
10 </TestSettings> No newline at end of file
@@ -0,0 +1,21
1 <?xml version="1.0" encoding="UTF-8"?>
2 <TestSettings name="Trace and Test Impact" id="8057bc26-bca1-4225-a128-52e89dd1b7d3" xmlns="http://microsoft.com/schemas/VisualStudio/TeamTest/2010">
3 <Description>These are test settings for Trace and Test Impact.</Description>
4 <Execution>
5 <TestTypeSpecific />
6 <AgentRule name="Execution Agents">
7 <DataCollectors>
8 <DataCollector uri="datacollector://microsoft/SystemInfo/1.0" assemblyQualifiedName="Microsoft.VisualStudio.TestTools.DataCollection.SystemInfo.SystemInfoDataCollector, Microsoft.VisualStudio.TestTools.DataCollection.SystemInfo, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" friendlyName="System Information">
9 </DataCollector>
10 <DataCollector uri="datacollector://microsoft/ActionLog/1.0" assemblyQualifiedName="Microsoft.VisualStudio.TestTools.ManualTest.ActionLog.ActionLogPlugin, Microsoft.VisualStudio.TestTools.ManualTest.ActionLog, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" friendlyName="Actions">
11 </DataCollector>
12 <DataCollector uri="datacollector://microsoft/HttpProxy/1.0" assemblyQualifiedName="Microsoft.VisualStudio.TraceCollector.HttpProxyCollector, Microsoft.VisualStudio.TraceCollector, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" friendlyName="ASP.NET Client Proxy for IntelliTrace and Test Impact">
13 </DataCollector>
14 <DataCollector uri="datacollector://microsoft/TestImpact/1.0" assemblyQualifiedName="Microsoft.VisualStudio.TraceCollector.TestImpactDataCollector, Microsoft.VisualStudio.TraceCollector, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" friendlyName="Test Impact">
15 </DataCollector>
16 <DataCollector uri="datacollector://microsoft/TraceDebugger/1.0" assemblyQualifiedName="Microsoft.VisualStudio.TraceCollector.TraceDebuggerDataCollector, Microsoft.VisualStudio.TraceCollector, Version=10.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a" friendlyName="IntelliTrace">
17 </DataCollector>
18 </DataCollectors>
19 </AgentRule>
20 </Execution>
21 </TestSettings> No newline at end of file
General Comments 0
You need to be logged in to leave comments. Login now