implab/ImplabNet Commit - r80:4f20870d0816

added memory barriers

cin -

r80:4f20870d0816 v2

parent child

Context file:

r80:4f20870d0816

Collapse all files

Implab/SyncPool.cs created 644 +85 0

@@ -0,0 +1,85
	1	using System;
	2	using Implab.Parallels;
	3	using System.Threading;
	4
	5	namespace Implab {
	6	/*public class SyncPool<T> : IDisposable {
	7	readonly Func<T> m_factory;
	8	readonly Action<T> m_cleanup;
	9	readonly int m_size;
	10	readonly MTQueue<T> m_queue = new MTQueue<T>();
	11
	12	volatile bool m_disposed;
	13
	14	volatile int m_count;
	15
	16	public SyncPool(Func<T> factory, Action<T> cleanup, int size) {
	17	Safe.ArgumentNotNull(factory, "factory");
	18	Safe.ArgumentInRange(size, 1, size, "size");
	19
	20	m_factory = factory;
	21	m_cleanup = cleanup;
	22	m_size = size;
	23	}
	24
	25	public SyncPool(Func<T> factory, Action<T> cleanup) : this(factory,cleanup,Environment.ProcessorCount+1) {
	26	}
	27
	28	public SyncPool(Func<T> factory) : this(factory,null,Environment.ProcessorCount+1) {
	29	}
	30
	31	public SyncPoolWrapper<T> Allocate() {
	32	if (m_disposed)
	33	throw new ObjectDisposedException(this.ToString());
	34
	35	T instance;
	36	if (m_queue.TryDequeue(out instance)) {
	37	Interlocked.Decrement(ref m_count);
	38	return instance;
	39	} else {
	40	instance = m_factory();
	41	}
	42	return new SyncPoolWrapper<T>(instance, this);
	43	}
	44
	45	public void Release(T instance) {
	46	if (m_count < m_size && !m_disposed) {
	47	Interlocked.Increment(ref m_count);
	48
	49	if (m_cleanup != null)
	50	m_cleanup(instance);
	51
	52	m_queue.Enqueue(instance);
	53
	54	// пока элемент возвращался в кеш, была начата операция освобождения всего кеша
	55	// и возможно уже законцена, в таком случае следует извлечь элемент обратно и
	56	// освободить его. Если операция освобождения кеша еще не заврешилась, то будет
	57	// изъят и освобожден произвольный элемен, что не повлияет на ход всего процесса.
	58	if (m_disposed && m_queue.TryDequeue(out instance))
	59	Safe.Dispose(instance);
	60
	61	} else {
	62	Safe.Dispose(instance);
	63	}
	64	}
	65
	66	protected virtual void Dispose(bool disposing) {
	67	if (disposing) {
	68	m_disposed = true;
	69	T instance;
	70	while (m_queue.TryDequeue(out instance))
	71	Safe.Dispose(instance);
	72	}
	73	}
	74
	75	#region IDisposable implementation
	76
	77	public void Dispose() {
	78	Dispose(true);
	79	GC.SuppressFinalize(this);
	80	}
	81
	82	#endregion
	83	}*/
	84	}
	85

Implab/SyncPoolWrapper.cs created 644 +24 0

@@ -0,0 +1,24
	1	using System;
	2
	3	namespace Implab {
	4	/*public struct SyncPoolWrapper<T> : IDisposable {
	5	readonly T m_value;
	6	readonly SyncPool<T> m_pool;
	7
	8	internal SyncPoolWrapper(T value, SyncPool<T> pool) {
	9	m_value = value;
	10	m_pool = pool;
	11	}
	12
	13	public T Value {
	14	get { return m_value; }
	15	}
	16
	17	#region IDisposable implementation
	18	public void Dispose() {
	19	m_pool.Release(m_value);
	20	}
	21	#endregion
	22	}*/
	23	}
	24

Implab.Test/AsyncTests.cs +1 -1

             using System;
             using System.Reflection;
             using System.Threading;
             using Implab.Parallels;
             #if MONO
             using NUnit.Framework;
             using TestClassAttribute = NUnit.Framework.TestFixtureAttribute;
             using TestMethod = NUnit.Framework.TestAttribute;
             #else
             using Microsoft.VisualStudio.TestTools.UnitTesting;
             #endif
             namespace Implab.Test {
                 [TestClass]
                 public class AsyncTests {
                     [TestMethod]
                     public void ResolveTest() {
                         int res = -1;
                         var p = new Promise<int>();
                         p.Then(x => res = x);
                         p.Resolve(100);
                         Assert.AreEqual(100, res);
                     }
                     [TestMethod]
                     public void RejectTest() {
                         int res = -1;
                         Exception err = null;
                         var p = new Promise<int>();
                         p.Then(
                             x => res = x,
                             e => {
                                 err = e;
                                 return -2;
                             }
                         );
                         p.Reject(new ApplicationException("error"));
                         Assert.AreEqual(res, -1);
                         Assert.AreEqual(err.Message, "error");
                     }
                     [TestMethod]
                     public void CancelExceptionTest() {
                         var p = new Promise<bool>();
                         p.Cancel();
                         var p2 = p.Cancelled(() => {
                             throw new ApplicationException("CANCELLED");
                         });
                         try {
                             p2.Join();
                             Assert.Fail();
                         } catch (ApplicationException err) {
                             Assert.AreEqual("CANCELLED", err.InnerException.Message);
                         }
                     }
                     [TestMethod]
                     public void ContinueOnCancelTest() {
                         var p = new Promise<bool>();
                         p.Cancel();
                         var p2 = p
                             .Cancelled(() => {
                                 throw new ApplicationException("CANCELLED");
                             })
                             .Error(e => true);
                         Assert.AreEqual(true, p2.Join());
                     }
                     [TestMethod]
                     public void JoinSuccessTest() {
                         var p = new Promise<int>();
                         p.Resolve(100);
                         Assert.AreEqual(p.Join(), 100);
                     }
                     [TestMethod]
                     public void JoinFailTest() {
                         var p = new Promise<int>();
                         p.Reject(new ApplicationException("failed"));
                         try {
                             p.Join();
                             throw new ApplicationException("WRONG!");
                         } catch (TargetInvocationException err) {
                             Assert.AreEqual(err.InnerException.Message, "failed");
                         } catch {
                             Assert.Fail("Got wrong excaption");
                         }
                     }
                     [TestMethod]
                     public void MapTest() {
                         var p = new Promise<int>();
                         var p2 = p.Then(x => x.ToString());
                         p.Resolve(100);
                         Assert.AreEqual(p2.Join(), "100");
                     }
                     [TestMethod]
                     public void FixErrorTest() {
                         var p = new Promise<int>();
                         var p2 = p.Error(e => 101);
                         p.Reject(new Exception());
                         Assert.AreEqual(p2.Join(), 101);
                     }
                     [TestMethod]
                     public void ChainTest() {
                         var p1 = new Promise<int>();
                         var p3 = p1.Chain(x => {
                             var p2 = new Promise<string>();
                             p2.Resolve(x.ToString());
                             return p2;
                         });
                         p1.Resolve(100);
                         Assert.AreEqual(p3.Join(), "100");
                     }
                     [TestMethod]
                     public void PoolTest() {
                         var pid = Thread.CurrentThread.ManagedThreadId;
                         var p = AsyncPool.Invoke(() => Thread.CurrentThread.ManagedThreadId);
                         Assert.AreNotEqual(pid, p.Join());
                     }
                     [TestMethod]
                     public void WorkerPoolSizeTest() {
                         var pool = new WorkerPool(5, 10, 0);
                         Assert.AreEqual(5, pool.PoolSize);
                         pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
                         pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
                         pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
                         Assert.AreEqual(5, pool.PoolSize);
                         for (int i = 0; i < 100; i++)
                             pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
                         Thread.Sleep(200);
                         Assert.AreEqual(10, pool.PoolSize);
                         pool.Dispose();
                     }
                     [TestMethod]
                     public void WorkerPoolCorrectTest() {
                         var pool = new WorkerPool(0,1000,100);
                         const int iterations = 1000;
                         int pending = iterations;
                         var stop = new ManualResetEvent(false);
                         var count = 0;
                         for (int i = 0; i < iterations; i++) {
                             pool
                                 .Invoke(() => 1)
                                 .Then(x => Interlocked.Add(ref count, x))
                                 .Then(x => Math.Log10(x))
                                 .Anyway(() => {
                                     Interlocked.Decrement(ref pending);
                                     if (pending == 0)
                                         stop.Set();
                                 });
                         }
                         stop.WaitOne();
                         Assert.AreEqual(iterations, count);
                         Console.WriteLine("Max threads: {0}", pool.MaxRunningThreads);
                         pool.Dispose();
                     }
                     [TestMethod]
                     public void WorkerPoolDisposeTest() {
                         var pool = new WorkerPool(5, 20);
                         Assert.AreEqual(5, pool.PoolSize);
                         pool.Dispose();
                         Thread.Sleep(500);
                         Assert.AreEqual(0, pool.PoolSize);
                         pool.Dispose();
                     }
                     [TestMethod]
                     public void MTQueueTest() {
                         var queue = new MTQueue<int>();
                         int res;
                         queue.Enqueue(10);
                         Assert.IsTrue(queue.TryDequeue(out res));
                         Assert.AreEqual(10, res);
                         Assert.IsFalse(queue.TryDequeue(out res));
                         for (int i = 0; i < 1000; i++)
                             queue.Enqueue(i);
                         for (int i = 0; i < 1000; i++) {
                             queue.TryDequeue(out res);
                             Assert.AreEqual(i, res);
                         }
                         int writers = 0;
                         int readers = 0;
                         var stop = new ManualResetEvent(false);
                         int total = 0;
                         const int itemsPerWriter = 10000;
                         const int writersCount = 10;
                         for (int i = 0; i < writersCount; i++) {
                             Interlocked.Increment(ref writers);
                             AsyncPool
                                 .InvokeNewThread(() => {
                                     for (int ii = 0; ii < itemsPerWriter; ii++) {
                                         queue.Enqueue(1);
                                     }
                                     return 1;
                                 })
                                 .Anyway(() => Interlocked.Decrement(ref writers));
                         }
                         for (int i = 0; i < 10; i++) {
                             Interlocked.Increment(ref readers);
                             AsyncPool
                                 .InvokeNewThread(() => {
                                     int t;
                                     do {
                                         while (queue.TryDequeue(out t))
                                             Interlocked.Add(ref total, t);
                                     } while (writers > 0);
                                     return 1;
                                 })
                                 .Anyway(() => {
                                     Interlocked.Decrement(ref readers);
                                     if (readers == 0)
                                         stop.Set();
                                 });
                         }
                         stop.WaitOne();
                         Assert.AreEqual(itemsPerWriter * writersCount, total);
                     }
                     [TestMethod]
                     public void ParallelMapTest() {
                         const int count = 100000;
                         var args = new double[count];
                         var rand = new Random();
                         for (int i = 0; i < count; i++)
                             args[i] = rand.NextDouble();
                         var t = Environment.TickCount;
                         var res = args.ParallelMap(x => Math.Sin(x*x), 4).Join();
                         Console.WriteLine("Map complete in {0} ms", Environment.TickCount - t);
                         t = Environment.TickCount;
                         for (int i = 0; i < count; i++)
                             Assert.AreEqual(Math.Sin(args[i] * args[i]), res[i]);
                         Console.WriteLine("Verified in {0} ms", Environment.TickCount - t);
                     }
                     [TestMethod]
                     public void ChainedMapTest() {
-                        using (var pool = new WorkerPool(0,100,100)) {
+                        using (var pool = new WorkerPool(0,10,100)) {
                             const int count = 10000;
                             var args = new double[count];
                             var rand = new Random();
                             for (int i = 0; i < count; i++)
                                 args[i] = rand.NextDouble();
                             var t = Environment.TickCount;
                             var res = args
                                 .ChainedMap(
                                     // Analysis disable once AccessToDisposedClosure
                                     x => pool.Invoke(
                                         () => Math.Sin(x * x)
                                     ),
                                 )
                                 .Join();
                             Console.WriteLine("Map complete in {0} ms", Environment.TickCount - t);
                             t = Environment.TickCount;
                             for (int i = 0; i < count; i++)
                                 Assert.AreEqual(Math.Sin(args[i] * args[i]), res[i]);
                             Console.WriteLine("Verified in {0} ms", Environment.TickCount - t);
                             Console.WriteLine("Max workers: {0}", pool.MaxRunningThreads);
                         }
                     }
                     [TestMethod]
                     public void ParallelForEachTest() {
                         const int count = 100000;
                         var args = new int[count];
                         var rand = new Random();
                         for (int i = 0; i < count; i++)
                             args[i] = (int)(rand.NextDouble() * 100);
                         int result = 0;
                         var t = Environment.TickCount;
                         args.ParallelForEach(x => Interlocked.Add(ref result, x), 4).Join();
                         Console.WriteLine("Iteration complete in {0} ms, result: {1}", Environment.TickCount - t, result);
                         int result2 = 0;
                         t = Environment.TickCount;
                         for (int i = 0; i < count; i++)
                             result2 += args[i];
                         Assert.AreEqual(result2, result);
                         Console.WriteLine("Verified in {0} ms", Environment.TickCount - t);
                     }
                     [TestMethod]
                     public void ComplexCase1Test() {
                         var flags = new bool[3];
                         // op1 (aync 200ms) => op2 (async 200ms) => op3 (sync map)
                         var step1 = PromiseHelper
                             .Sleep(200, "Alan")
                             .Cancelled(() => flags[0] = true);
                         var p = step1
                             .Chain(x =>
                                 PromiseHelper
                                     .Sleep(200, "Hi, " + x)
                                     .Then(y => y)
                                     .Cancelled(() => flags[1] = true)
                             )
                             .Cancelled(() => flags[2] = true);
                         step1.Join();
                         p.Cancel();
                         try {
                             Assert.AreEqual(p.Join(), "Hi, Alan");
                             Assert.Fail("Shouldn't get here");
                         } catch (OperationCanceledException) {
                         }
                         Assert.IsFalse(flags[0]);
                         Assert.IsTrue(flags[1]);
                         Assert.IsTrue(flags[2]);
                     }
                     [TestMethod]
                     public void ChainedCancel1Test() {
                         // при отмене сцепленной асинхронной операции все обещание должно
                         // завершаться ошибкой OperationCanceledException
                         var p = PromiseHelper
                             .Sleep(1, "Hi, HAL!")
                             .Then(x => {
                                 // запускаем две асинхронные операции
                                 var result = PromiseHelper.Sleep(1000, "HEM ENABLED!!!");
                                 // вторая операция отменяет первую до завершения
                                 PromiseHelper
                                     .Sleep(100, "HAL, STOP!")
                                     .Then(result.Cancel);
                                 return result;
                             });
                         try {
                             p.Join();
                         } catch (TargetInvocationException err) {
                             Assert.IsTrue(err.InnerException is OperationCanceledException);
                         }
                     }
                     [TestMethod]
                     public void ChainedCancel2Test() {
                         // при отмене цепочки обещаний, вложенные операции также должны отменяться
                         var pSurvive = new Promise<bool>();
                         var hemStarted = new ManualResetEvent(false);
                         var p = PromiseHelper
                             .Sleep(1, "Hi, HAL!")
                             .Chain(x => {
                                 hemStarted.Set();
                                 // запускаем две асинхронные операции
                                 var result = PromiseHelper
                                     .Sleep(10000, "HEM ENABLED!!!")
                                     .Then(s => pSurvive.Resolve(false));
                                 result
                                     .Cancelled(() => pSurvive.Resolve(true));
                                 return result;
                             });
                         hemStarted.WaitOne();
                         p.Cancel();
                         try {
                             p.Join();
                         } catch (OperationCanceledException) {
                             Assert.IsTrue(pSurvive.Join());
                         }
                     }
                 }
             }

Implab.mono.sln 0 -3

             Microsoft Visual Studio Solution File, Format Version 11.00
             # Visual Studio 2010
             Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab", "Implab\Implab.csproj", "{F550F1F8-8746-4AD0-9614-855F4C4B7F05}"
             EndProject
             Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{CE8D8D18-437A-445C-B662-4C2CE79A76F6}"
             	ProjectSection(SolutionItems) = preProject
             		Implab.vsmdi = Implab.vsmdi
             		Local.testsettings = Local.testsettings
             		TraceAndTestImpact.testsettings = TraceAndTestImpact.testsettings
             	EndProjectSection
             EndProject
             Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Fx", "Implab.Fx\Implab.Fx.csproj", "{06E706F8-6881-43EB-927E-FFC503AF6ABC}"
             EndProject
             Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Tests", "Tests", "{BCA337C3-BFDC-4825-BBDB-E6D467E4E452}"
             EndProject
             Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Test.mono", "Implab.Test\Implab.Test.mono.csproj", "{2BD05F84-E067-4B87-9477-FDC2676A21C6}"
             EndProject
-            Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Implab.Fx.Test.mono", "Implab.Fx.Test\Implab.Fx.Test.mono.csproj", "{2BD05F84-E067-4B87-9477-FDC2676A21C6}"
-            EndProject
             Global
             	GlobalSection(SolutionConfigurationPlatforms) = preSolution
             		Debug|Any CPU = Debug|Any CPU
             		Release|Any CPU = Release|Any CPU
             		Debug 4.5|Any CPU = Debug 4.5|Any CPU
             		Release 4.5|Any CPU = Release 4.5|Any CPU
             	EndGlobalSection
             	GlobalSection(ProjectConfigurationPlatforms) = postSolution
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug 4.5|Any CPU.ActiveCfg = Debug 4.5|Any CPU
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug 4.5|Any CPU.Build.0 = Debug 4.5|Any CPU
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Debug|Any CPU.Build.0 = Debug|Any CPU
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release 4.5|Any CPU.ActiveCfg = Release 4.5|Any CPU
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release 4.5|Any CPU.Build.0 = Release 4.5|Any CPU
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release|Any CPU.ActiveCfg = Release|Any CPU
             		{06E706F8-6881-43EB-927E-FFC503AF6ABC}.Release|Any CPU.Build.0 = Release|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug 4.5|Any CPU.ActiveCfg = Debug 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug 4.5|Any CPU.ActiveCfg = Debug 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug 4.5|Any CPU.Build.0 = Debug 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug 4.5|Any CPU.Build.0 = Debug 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug|Any CPU.Build.0 = Debug|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Debug|Any CPU.Build.0 = Debug|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release 4.5|Any CPU.ActiveCfg = Release 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release 4.5|Any CPU.ActiveCfg = Release 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release 4.5|Any CPU.Build.0 = Release 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release 4.5|Any CPU.Build.0 = Release 4.5|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release|Any CPU.ActiveCfg = Release|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release|Any CPU.ActiveCfg = Release|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release|Any CPU.Build.0 = Release|Any CPU
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6}.Release|Any CPU.Build.0 = Release|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Debug 4.5|Any CPU.ActiveCfg = Debug 4.5|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Debug 4.5|Any CPU.Build.0 = Debug 4.5|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Debug|Any CPU.Build.0 = Debug|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Release 4.5|Any CPU.ActiveCfg = Release 4.5|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Release 4.5|Any CPU.Build.0 = Release 4.5|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Release|Any CPU.ActiveCfg = Release|Any CPU
             		{2F31E405-E267-4195-A05D-574093C21209}.Release|Any CPU.Build.0 = Release|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug 4.5|Any CPU.ActiveCfg = Debug 4.5|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug 4.5|Any CPU.Build.0 = Debug 4.5|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Debug|Any CPU.Build.0 = Debug|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release 4.5|Any CPU.ActiveCfg = Release 4.5|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release 4.5|Any CPU.Build.0 = Release 4.5|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release|Any CPU.ActiveCfg = Release|Any CPU
             		{63F92C0C-61BF-48C0-A377-8D67C3C661D0}.Release|Any CPU.Build.0 = Release|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug 4.5|Any CPU.ActiveCfg = Debug 4.5|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug 4.5|Any CPU.Build.0 = Debug 4.5|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Debug|Any CPU.Build.0 = Debug|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release 4.5|Any CPU.ActiveCfg = Release 4.5|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release 4.5|Any CPU.Build.0 = Release 4.5|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release|Any CPU.ActiveCfg = Release|Any CPU
             		{F550F1F8-8746-4AD0-9614-855F4C4B7F05}.Release|Any CPU.Build.0 = Release|Any CPU
             	EndGlobalSection
             	GlobalSection(NestedProjects) = preSolution
             		{2BD05F84-E067-4B87-9477-FDC2676A21C6} = {BCA337C3-BFDC-4825-BBDB-E6D467E4E452}
-            		{2BD05F84-E067-4B87-9477-FDC2676A21C6} = {BCA337C3-BFDC-4825-BBDB-E6D467E4E452}
             	EndGlobalSection
             	GlobalSection(MonoDevelopProperties) = preSolution
             		StartupItem = Implab\Implab.csproj
             		Policies = $0
             		$0.CSharpFormattingPolicy = $1
             		$1.IndentSwitchBody = True
             		$1.NamespaceBraceStyle = EndOfLine
             		$1.ClassBraceStyle = EndOfLine
             		$1.InterfaceBraceStyle = EndOfLine
             		$1.StructBraceStyle = EndOfLine
             		$1.EnumBraceStyle = EndOfLine
             		$1.MethodBraceStyle = EndOfLine
             		$1.ConstructorBraceStyle = EndOfLine
             		$1.DestructorBraceStyle = EndOfLine
             		$1.BeforeMethodDeclarationParentheses = False
             		$1.BeforeMethodCallParentheses = False
             		$1.BeforeConstructorDeclarationParentheses = False
             		$1.NewLineBeforeConstructorInitializerColon = NewLine
             		$1.NewLineAfterConstructorInitializerColon = SameLine
             		$1.BeforeIndexerDeclarationBracket = False
             		$1.BeforeDelegateDeclarationParentheses = False
             		$1.NewParentheses = False
             		$1.SpacesBeforeBrackets = False
             		$1.inheritsSet = Mono
             		$1.inheritsScope = text/x-csharp
             		$1.scope = text/x-csharp
             		$0.TextStylePolicy = $2
             		$2.FileWidth = 120
             		$2.EolMarker = Unix
             		$2.inheritsSet = VisualStudio
             		$2.inheritsScope = text/plain
             		$2.scope = text/x-csharp
             		$0.DotNetNamingPolicy = $3
             		$3.DirectoryNamespaceAssociation = PrefixedHierarchical
             		$3.ResourceNamePolicy = MSBuild
             		$0.TextStylePolicy = $4
             		$4.FileWidth = 120
             		$4.TabsToSpaces = False
             		$4.inheritsSet = VisualStudio
             		$4.inheritsScope = text/plain
             		$4.scope = application/xml
             		$0.XmlFormattingPolicy = $5
             		$5.inheritsSet = Mono
             		$5.inheritsScope = application/xml
             		$5.scope = application/xml
             		$0.TextStylePolicy = $6
             		$6.FileWidth = 120
             		$6.TabsToSpaces = False
             		$6.inheritsSet = VisualStudio
             		$6.inheritsScope = text/plain
             		$6.scope = text/plain
             		$0.NameConventionPolicy = $7
             		$7.Rules = $8
             		$8.NamingRule = $9
             		$9.Name = Namespaces
             		$9.AffectedEntity = Namespace
             		$9.VisibilityMask = VisibilityMask
             		$9.NamingStyle = PascalCase
             		$9.IncludeInstanceMembers = True
             		$9.IncludeStaticEntities = True
             		$8.NamingRule = $10
             		$10.Name = Types
             		$10.AffectedEntity = Class, Struct, Enum, Delegate
             		$10.VisibilityMask = VisibilityMask
             		$10.NamingStyle = PascalCase
             		$10.IncludeInstanceMembers = True
             		$10.IncludeStaticEntities = True
             		$8.NamingRule = $11
             		$11.Name = Interfaces
             		$11.RequiredPrefixes = $12
             		$12.String = I
             		$11.AffectedEntity = Interface
             		$11.VisibilityMask = VisibilityMask
             		$11.NamingStyle = PascalCase
             		$11.IncludeInstanceMembers = True
             		$11.IncludeStaticEntities = True
             		$8.NamingRule = $13
             		$13.Name = Attributes
             		$13.RequiredSuffixes = $14
             		$14.String = Attribute
             		$13.AffectedEntity = CustomAttributes
             		$13.VisibilityMask = VisibilityMask
             		$13.NamingStyle = PascalCase
             		$13.IncludeInstanceMembers = True
             		$13.IncludeStaticEntities = True
             		$8.NamingRule = $15
             		$15.Name = Event Arguments
             		$15.RequiredSuffixes = $16
             		$16.String = EventArgs
             		$15.AffectedEntity = CustomEventArgs
             		$15.VisibilityMask = VisibilityMask
             		$15.NamingStyle = PascalCase
             		$15.IncludeInstanceMembers = True
             		$15.IncludeStaticEntities = True
             		$8.NamingRule = $17
             		$17.Name = Exceptions
             		$17.RequiredSuffixes = $18
             		$18.String = Exception
             		$17.AffectedEntity = CustomExceptions
             		$17.VisibilityMask = VisibilityMask
             		$17.NamingStyle = PascalCase
             		$17.IncludeInstanceMembers = True
             		$17.IncludeStaticEntities = True
             		$8.NamingRule = $19
             		$19.Name = Methods
             		$19.AffectedEntity = Methods
             		$19.VisibilityMask = VisibilityMask
             		$19.NamingStyle = PascalCase
             		$19.IncludeInstanceMembers = True
             		$19.IncludeStaticEntities = True
             		$8.NamingRule = $20
             		$20.Name = Static Readonly Fields
             		$20.AffectedEntity = ReadonlyField
             		$20.VisibilityMask = Internal, Protected, Public
             		$20.NamingStyle = PascalCase
             		$20.IncludeInstanceMembers = False
             		$20.IncludeStaticEntities = True
             		$8.NamingRule = $21
             		$21.Name = Fields (Non Private)
             		$21.AffectedEntity = Field
             		$21.VisibilityMask = Internal, Public
             		$21.NamingStyle = CamelCase
             		$21.IncludeInstanceMembers = True
             		$21.IncludeStaticEntities = True
             		$8.NamingRule = $22
             		$22.Name = ReadOnly Fields (Non Private)
             		$22.AffectedEntity = ReadonlyField
             		$22.VisibilityMask = Internal, Public
             		$22.NamingStyle = CamelCase
             		$22.IncludeInstanceMembers = True
             		$22.IncludeStaticEntities = False
             		$8.NamingRule = $23
             		$23.Name = Fields (Private)
             		$23.RequiredPrefixes = $24
             		$24.String = m_
             		$23.AffectedEntity = Field, ReadonlyField
             		$23.VisibilityMask = Private, Protected
             		$23.NamingStyle = CamelCase
             		$23.IncludeInstanceMembers = True
             		$23.IncludeStaticEntities = False
             		$8.NamingRule = $25
             		$25.Name = Static Fields (Private)
             		$25.RequiredPrefixes = $26
             		$26.String = _
             		$25.AffectedEntity = Field
             		$25.VisibilityMask = Private
             		$25.NamingStyle = CamelCase
             		$25.IncludeInstanceMembers = False
             		$25.IncludeStaticEntities = True
             		$8.NamingRule = $27
             		$27.Name = ReadOnly Fields (Private)
             		$27.RequiredPrefixes = $28
             		$28.String = m_
             		$27.AffectedEntity = ReadonlyField
             		$27.VisibilityMask = Private, Protected
             		$27.NamingStyle = CamelCase
             		$27.IncludeInstanceMembers = True
             		$27.IncludeStaticEntities = False
             		$8.NamingRule = $29
             		$29.Name = Constant Fields
             		$29.AffectedEntity = ConstantField
             		$29.VisibilityMask = VisibilityMask
             		$29.NamingStyle = AllUpper
             		$29.IncludeInstanceMembers = True
             		$29.IncludeStaticEntities = True
             		$8.NamingRule = $30
             		$30.Name = Properties
             		$30.AffectedEntity = Property
             		$30.VisibilityMask = VisibilityMask
             		$30.NamingStyle = PascalCase
             		$30.IncludeInstanceMembers = True
             		$30.IncludeStaticEntities = True
             		$8.NamingRule = $31
             		$31.Name = Events
             		$31.AffectedEntity = Event
             		$31.VisibilityMask = VisibilityMask
             		$31.NamingStyle = PascalCase
             		$31.IncludeInstanceMembers = True
             		$31.IncludeStaticEntities = True
             		$8.NamingRule = $32
             		$32.Name = Enum Members
             		$32.AffectedEntity = EnumMember
             		$32.VisibilityMask = VisibilityMask
             		$32.NamingStyle = PascalCase
             		$32.IncludeInstanceMembers = True
             		$32.IncludeStaticEntities = True
             		$8.NamingRule = $33
             		$33.Name = Parameters
             		$33.AffectedEntity = Parameter, LocalVariable
             		$33.VisibilityMask = VisibilityMask
             		$33.NamingStyle = CamelCase
             		$33.IncludeInstanceMembers = True
             		$33.IncludeStaticEntities = True
             		$8.NamingRule = $34
             		$34.Name = Type Parameters
             		$34.RequiredPrefixes = $35
             		$35.String = T
             		$34.AffectedEntity = TypeParameter
             		$34.VisibilityMask = VisibilityMask
             		$34.NamingStyle = PascalCase
             		$34.IncludeInstanceMembers = True
             		$34.IncludeStaticEntities = True
             	EndGlobalSection
             	GlobalSection(TestCaseManagementSettings) = postSolution
             		CategoryFile = Implab.vsmdi
             	EndGlobalSection
             	GlobalSection(SolutionProperties) = preSolution
             		HideSolutionNode = FALSE
             	EndGlobalSection
             EndGlobal

Implab/Implab.csproj +4 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>
+                <ProductVersion>8.0.30703</ProductVersion>
+                <SchemaVersion>2.0</SchemaVersion>
               </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>
               <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\TraceContext.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="SyncPool.cs" />
+                <Compile Include="SyncPoolWrapper.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/JSON/JSONXmlReaderOptions.cs +4 -1

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             using System.Xml;
             namespace Implab.JSON {
                 /// <summary>
                 /// Набор необязательных параметров для <see cref="JSONXmlReader"/>, позволяющий управлять процессом
                 /// интерпретации <c>JSON</c> документа.
                 /// </summary>
                 public class JSONXmlReaderOptions {
                     /// <summary>
                     /// Пространство имен в котором будут располагаться читаемые элементы документа
                     /// </summary>
                     public string NamespaceURI {
                         get;
                         set;
                     }
                     /// <summary>
-                    /// Интерпретировать массивы как множественные элементы (убирает один уровень вложенности)
+                    /// Интерпретировать массивы как множественные элементы (убирает один уровень вложенности), иначе массив
+                    /// представляется в виде узла, дочерними элементами которого являются элементы массива, имена дочерних элементов
+                    /// определяются свойством <see cref="ArrayItemName"/>. По умолчанию <c>false</c>.
                     /// </summary>
                     public bool FlattenArrays {
                         get;
                         set;
                     }
                     /// <summary>
                     /// Префикс, для узлов документа
                     /// </summary>
                     public string NodesPrefix {
                         get;
                         set;
                     }
                     /// <summary>
                     /// Имя корневого элемента в xml документе
                     /// </summary>
                     public string RootName {
                         get;
                         set;
                     }
                     /// <summary>
                     /// Имя элемента для массивов, если не включена опция <see cref="FlattenArrays"/>.
+                    /// По умолчанию <c>item</c>.
                     /// </summary>
                     public string ArrayItemName {
                         get;
                         set;
                     }
                     /// <summary>
                     /// Таблица атомизированных строк для построения документа.
                     /// </summary>
                     public XmlNameTable NameTable {
                         get;
                         set;
                     }
                 }
             }

Implab/Parallels/ArrayTraits.cs +17 -10

             using Implab.Diagnostics;
             using System;
             using System.Collections.Generic;
             using System.Diagnostics;
             using System.Linq;
             using System.Text;
             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 TraceContext m_traceContext;
                         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_traceContext = TraceContext.Snapshot();
                             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.Fork(m_traceContext);
                             base.Worker();
                         }
                         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 TraceContext m_traceContext;
                         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_traceContext = TraceContext.Snapshot();
                             m_promise.Anyway(Dispose);
                             InitPool();
                         }
                         public Promise<TDst[]> Promise {
                             get {
                                 return m_promise;
                             }
                         }
                         protected override void Worker() {
                             TraceContext.Fork(m_traceContext);
                             base.Worker();
                         }
                         protected override bool TryDequeue(out int unit) {
                             unit = Interlocked.Increment(ref m_next) - 1;
                             return unit >= m_source.Length ? false : true;
                         }
                         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, ResultMapper<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 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;
-                        var semaphore = new Semaphore(threads, threads);
+                        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;
-                                semaphore.WaitOne();
+                                lock(locker) {
+                                    while(slots == 0)
+                                        Monitor.Wait(locker);
+                                    slots--;
+                                }
                                 try {
-                                    var p1 = transform(source[i]);
+                                    transform(source[i])
-                                    p1.Anyway(() => semaphore.Release());
+                                        .Anyway(() => {
-                                    p1.Then(
+                                            lock(locker) {
+                                                slots ++;
+                                                Monitor.Pulse(locker);
+                                            }
+                                        })
+                                        .Last(
                                             x => {
                                                 res[idx] = x;
                                                 var left = Interlocked.Decrement(ref pending);
                                                 if (left == 0)
                                                     promise.Resolve(res);
                                             },
-                                        e => {
+                                            e => promise.Reject(e)
-                                            promise.Reject(e);
-                                            throw new TransientPromiseException(e);
                                         );
                                 } catch (Exception e) {
                                     promise.Reject(e);
                                 }
                             }
                             return 0;
                         });
-                        return promise.Anyway(semaphore.Dispose);
+                        return promise;
                     }
                 }
             }

Implab/Parallels/DispatchPool.cs +43 -34

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             using System.Threading;
             using System.Diagnostics;
             namespace Implab.Parallels {
                 public abstract class DispatchPool<TUnit> : IDisposable {
                     readonly int m_minThreads;
                     readonly int m_maxThreads;
+                    readonly int m_releaseTimeout = 100; // the timeout while the working thread will wait for the new tasks before exit
                     int m_createdThreads = 0; // the current size of the pool
                     int m_activeThreads = 0; // the count of threads which are active
                     int m_sleepingThreads = 0; // the count of currently inactive threads
                     int m_maxRunningThreads = 0; // the meximum reached size of the pool
                     int m_exitRequired = 0; // the pool is going to shutdown, all unused workers are released
-                    int m_releaseTimeout = 100; // the timeout while the working thread will wait for the new tasks before exit
                     int m_wakeEvents = 0; // the count of wake events
-                    AutoResetEvent m_hasTasks = new AutoResetEvent(false);
+                    readonly object m_signalLocker = new object();
                     protected DispatchPool(int min, int max) {
                         if (min < 0)
                             throw new ArgumentOutOfRangeException("min");
                         if (max <= 0)
                             throw new ArgumentOutOfRangeException("max");
                         if (min > max)
                             min = max;
                         m_minThreads = min;
                         m_maxThreads = max;
                     }
                     protected DispatchPool(int threads)
                         : this(threads, threads) {
                     }
                     protected DispatchPool() {
                         int maxThreads, maxCP;
                         ThreadPool.GetMaxThreads(out maxThreads, out maxCP);
                         m_minThreads = 0;
                         m_maxThreads = maxThreads;
                     }
                     protected void InitPool() {
                         for (int i = 0; i < m_minThreads; i++)
                             StartWorker();
                     }
                     public int PoolSize {
                         get {
+                            Thread.MemoryBarrier();
                             return m_createdThreads;
                         }
                     }
                     public int ActiveThreads {
                         get {
+                            Thread.MemoryBarrier();
                             return m_activeThreads;
                         }
                     }
                     public int MaxRunningThreads {
                         get {
+                            Thread.MemoryBarrier();
                             return m_maxRunningThreads;
                         }
                     }
                     protected bool IsDisposed {
                         get {
-                            return m_exitRequired != 0;
+                            Thread.MemoryBarrier();
+                            return m_exitRequired == 1;
                         }
                     }
                     protected abstract bool TryDequeue(out TUnit unit);
-                    #region thread execution traits
+                    #region thread signaling traits
                     int SignalThread() {
                         var signals = Interlocked.Increment(ref m_wakeEvents);
                         if(signals == 1)
-                            m_hasTasks.Set();
+                            lock(m_signalLocker)
+                                Monitor.Pulse(m_signalLocker);
                         return signals;
                     }
                     bool FetchSignalOrWait(int timeout) {
                         var start = Environment.TickCount;
-                        // означает, что поток владеет блокировкой и при успешном получении сигнала должен
-                        // ее вернуть, чтобы другой ожидающий поток смог
-                        bool hasLock = false;
-                        do {
                         int signals;
+                        Thread.MemoryBarrier(); // m_wakeEvents volatile first read
                         do {
                             signals = m_wakeEvents;
                             if (signals == 0)
                                 break;
                         } while (Interlocked.CompareExchange(ref m_wakeEvents, signals - 1, signals) != signals);
-                            if (signals >= 1) {
+                        if (signals == 0) {
-                                if (signals > 1 && hasLock)
+                            // no signal is fetched
-                                    m_hasTasks.Set();
+                            lock(m_signalLocker) {
+                                while(m_wakeEvents == 0) {
+                                    if (timeout != -1)
+                                        timeout = Math.Max(0, timeout - (Environment.TickCount - start));
+                                    if(!Monitor.Wait(m_signalLocker,timeout))
+                                        return false; // timeout
+                                }
+                                // m_wakeEvents > 0
+                                if (Interlocked.Decrement(ref m_wakeEvents) > 0) //syncronized
+                                    Monitor.Pulse(m_signalLocker);
+                                // signal fetched
                                 return true;
                             }
-                            if (timeout != -1)
+                        } else {
-                                timeout = Math.Max(0, timeout - (Environment.TickCount - start));
+                            // signal fetched
+                            return true;
+                        }
-                            // если сигналов больше не осталось, то первый поток, который дошел сюда сбросит событие
-                            // и уйдет на пустой цикл, после чего заблокируется
-                            hasLock = true;
-                        } while (m_hasTasks.WaitOne(timeout));
-                        return false;
                     }
                     bool Sleep(int timeout) {
                         Interlocked.Increment(ref m_sleepingThreads);
                         if (FetchSignalOrWait(timeout)) {
                             Interlocked.Decrement(ref m_sleepingThreads);
                             return true;
                         } else {
                             Interlocked.Decrement(ref m_sleepingThreads);
                             return false;
                         }
                     }
                     #endregion
                     /// <summary>
                     /// Запускает либо новый поток, если раньше не было ни одного потока, либо устанавливает событие пробуждение одного спящего потока
                     /// </summary>
                     protected void GrowPool() {
-                        if (m_exitRequired != 0)
+                        Thread.MemoryBarrier();
+                        if (m_exitRequired == 1)
                             return;
                         if (m_sleepingThreads > m_wakeEvents) {
                             //Console.WriteLine("Waking threads (sleeps {0}, pending {1})", m_sleepingThreads, m_wakeEvents);
                             // all sleeping threads may gone
                             SignalThread(); // wake a sleeping thread;
                             // we can't check whether signal has been processed
                             // anyway it may take some time for the thread to start
                             // we will ensure that at least one thread is running
                             EnsurePoolIsAlive();
                         } else {
                             // if there is no sleeping threads in the pool
                             if (!StartWorker()) {
                                 // we haven't started a new thread, but the current can be on the way to terminate and it can't process the queue
                                 // send it a signal to spin again
                                 SignalThread();
                                 EnsurePoolIsAlive();
                             }
                         }
                     }
                     protected void EnsurePoolIsAlive() {
                         if (AllocateThreadSlot(1)) {
                             // if there were no threads in the pool
                             var worker = new Thread(this.Worker);
                             worker.IsBackground = true;
                             worker.Start();
                         }
                     }
                     protected virtual bool Suspend() {
                         //no tasks left, exit if the thread is no longer needed
                         bool last;
                         bool requestExit;
                         // if threads have a timeout before releasing
                         if (m_releaseTimeout > 0)
                             requestExit = !Sleep(m_releaseTimeout);
                         else
                             requestExit = true;
                         if (!requestExit)
                             return true;
                         // release unsused thread
                         if (requestExit && ReleaseThreadSlot(out last)) {
                             // in case at the moment the last thread was being released
                             // a new task was added to the queue, we need to try
                             // to revoke the thread to avoid the situation when the task is left unprocessed
                             if (last && FetchSignalOrWait(0)) { // FetchSignalOrWait(0) will fetch pending task or will return false
                                 SignalThread(); // since FetchSignalOrWait(0) has fetched the signal we need to reschedule it
                                 return AllocateThreadSlot(1); // ensure that at least one thread is alive
                             }
                             return false;
                         }
                         // wait till infinity
                         Sleep(-1);
                         return true;
                     }
                     #region thread slots traits
                     bool AllocateThreadSlot() {
                         int current;
                         // use spins to allocate slot for the new thread
                         do {
                             current = m_createdThreads;
-                            if (current >= m_maxThreads || m_exitRequired != 0)
+                            if (current >= m_maxThreads || m_exitRequired == 1)
                                 // no more slots left or the pool has been disposed
                                 return false;
                         } while (current != Interlocked.CompareExchange(ref m_createdThreads, current + 1, current));
                         UpdateMaxThreads(current + 1);
                         return true;
                     }
                     bool AllocateThreadSlot(int desired) {
                         if (desired - 1 != Interlocked.CompareExchange(ref m_createdThreads, desired, desired - 1))
                             return false;
                         UpdateMaxThreads(desired);
                         return true;
                     }
                     bool ReleaseThreadSlot(out bool last) {
                         last = false;
                         int current;
                         // use spins to release slot for the new thread
+                        Thread.MemoryBarrier();
                         do {
                             current = m_createdThreads;
                             if (current <= m_minThreads && m_exitRequired == 0)
                                 // the thread is reserved
                                 return false;
                         } while (current != Interlocked.CompareExchange(ref m_createdThreads, current - 1, current));
                         last = (current == 1);
                         return true;
                     }
                     /// <summary>
                     /// releases thread slot unconditionally, used during cleanup
                     /// </summary>
                     /// <returns>true - no more threads left</returns>
                     bool ReleaseThreadSlotAnyway() {
                         var left = Interlocked.Decrement(ref m_createdThreads);
                         return left == 0;
                     }
                     void UpdateMaxThreads(int count) {
                         int max;
                         do {
                             max = m_maxRunningThreads;
                             if (max >= count)
                                 break;
                         } while(max != Interlocked.CompareExchange(ref m_maxRunningThreads, count, max));
                     }
                     #endregion
                     bool StartWorker() {
                         if (AllocateThreadSlot()) {
                             // slot successfully allocated
                             var worker = new Thread(this.Worker);
                             worker.IsBackground = true;
+                            Interlocked.Increment(ref m_activeThreads);
                             worker.Start();
                             return true;
                         } else {
                             return false;
                         }
                     }
                     protected abstract void InvokeUnit(TUnit unit);
                     protected virtual void Worker() {
                         TUnit unit;
                         //Console.WriteLine("{0}: Active", Thread.CurrentThread.ManagedThreadId);
-                        Interlocked.Increment(ref m_activeThreads);
+                        int count = 0;;
+                        Thread.MemoryBarrier();
                         do {
                             // exit if requested
-                            if (m_exitRequired != 0) {
+                            if (m_exitRequired == 1) {
                                 // release the thread slot
                                 Interlocked.Decrement(ref m_activeThreads);
-                                if (ReleaseThreadSlotAnyway()) // it was the last worker
+                                if (!ReleaseThreadSlotAnyway()) // it was the last worker
-                                    m_hasTasks.Dispose();
-                                else
                                     SignalThread(); // wake next worker
                                 break;
                             }
                             // fetch task
                             if (TryDequeue(out unit)) {
                                 InvokeUnit(unit);
+                                count ++;
                                 continue;
                             }
                             Interlocked.Decrement(ref m_activeThreads);
+                            Console.WriteLine("{0}: Suspend processed({1})", Thread.CurrentThread.ManagedThreadId,count);
                             // entering suspend state
                             // keep this thread and wait
                             if (!Suspend())
                                 break;
+                            count = 0;
                             //Console.WriteLine("{0}: Awake", Thread.CurrentThread.ManagedThreadId);
                             Interlocked.Increment(ref m_activeThreads);
                         } while (true);
                         //Console.WriteLine("{0}: Exited", Thread.CurrentThread.ManagedThreadId);
                     }
                     protected virtual void Dispose(bool disposing) {
                         if (disposing) {
-                            if (m_exitRequired == 0) {
+                            if (0 == Interlocked.CompareExchange(ref m_exitRequired, 1, 0)) { // implies memory barrier
-                                if (Interlocked.CompareExchange(ref m_exitRequired, 1, 0) != 0)
-                                    return;
                                 // wake sleeping threads
                                 if (m_createdThreads > 0)
                                     SignalThread();
-                                else
-                                    m_hasTasks.Dispose();
                                 GC.SuppressFinalize(this);
                             }
                         }
                     }
                     public void Dispose() {
                         Dispose(true);
                     }
                     ~DispatchPool() {
                         Dispose(false);
                     }
                 }
             }

Implab/Parallels/MTQueue.cs +3 0

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             using System.Threading;
             namespace Implab.Parallels {
                 public class MTQueue<T> {
                     class Node {
                         public Node(T value) {
                             this.value = value;
                         }
                         public readonly T value;
                         public Node next;
                     }
                     Node m_first;
                     Node m_last;
                     public void Enqueue(T value) {
+                        Thread.MemoryBarrier();
                         var last = m_last;
                         var next = new Node(value);
                         while (last != Interlocked.CompareExchange(ref m_last, next, last))
                             last = m_last;
                         if (last != null)
                             last.next = next;
                         else
                             m_first = next;
                     }
                     public bool TryDequeue(out T value) {
                         Node first;
                         Node next = null;
                         value = default(T);
+                        Thread.MemoryBarrier();
                         do {
                             first = m_first;
                             if (first == null)
                                 return false;
                             next = first.next;
                             if (next == null) {
                                 // this is the last element,
                                 // then try to update the tail
                                 if (first != Interlocked.CompareExchange(ref m_last, null, first)) {
                                     // this is the race condition
                                     if (m_last == null)
                                         // the queue is empty
                                         return false;
                                     // tail has been changed, we need to restart
                                     continue;
                                 }
                                 // tail succesfully updated and first.next will never be changed
                                 // other readers will fail due to inconsistency m_last != m_fist && m_first.next == null
                                 // however the parallel writer may update the m_first since the m_last is null
                                 // so we need to fix inconsistency by setting m_first to null or if it has been
                                 // updated by the writer already then we should just to give up
                                 Interlocked.CompareExchange(ref m_first, null, first);
                                 break;
                             } else {
                                 if (first == Interlocked.CompareExchange(ref m_first, next, first))
                                     // head succesfully updated
                                     break;
                             }
                         } while (true);
                         value = first.value;
                         return true;
                     }
                 }
             }

Implab/Parallels/WorkerPool.cs +9 -1

             using System;
             using System.Collections.Generic;
             using System.Linq;
             using System.Text;
             using System.Threading;
             using System.Diagnostics;
             using Implab.Diagnostics;
             namespace Implab.Parallels {
                 public class WorkerPool : DispatchPool<Action> {
                     MTQueue<Action> m_queue = new MTQueue<Action>();
                     int m_queueLength = 0;
                     readonly int m_threshold = 1;
+                    int m_workers = 0;
                     public WorkerPool(int minThreads, int maxThreads, int threshold)
                         : base(minThreads, maxThreads) {
                         m_threshold = threshold;
+                        m_workers = minThreads;
                         InitPool();
                     }
                     public WorkerPool(int minThreads, int maxThreads) :
                         base(minThreads, maxThreads) {
+                        m_workers = minThreads;
                         InitPool();
                     }
                     public WorkerPool(int threads)
                         : base(threads) {
+                        m_workers = threads;
                         InitPool();
                     }
                     public WorkerPool()
                         : base() {
                         InitPool();
                     }
                     public Promise<T> Invoke<T>(Func<T> task) {
                         if (task == null)
                             throw new ArgumentNullException("task");
                         if (IsDisposed)
                             throw new ObjectDisposedException(ToString());
                         var promise = new Promise<T>();
                         var caller = TraceContext.Snapshot();
                         EnqueueTask(delegate() {
                             caller.Invoke(delegate() {
                                 try {
                                     promise.Resolve(task());
                                 } catch (Exception e) {
                                     promise.Reject(e);
                                 }
                             });
                         });
                         return promise;
                     }
                     protected void EnqueueTask(Action unit) {
                         Debug.Assert(unit != null);
                         var len = Interlocked.Increment(ref m_queueLength);
                         m_queue.Enqueue(unit);
-                        if (len > m_threshold*ActiveThreads)
+                        if (len > m_threshold * m_workers) {
+                            Interlocked.Increment(ref m_workers);
                             GrowPool();
                         }
+                    }
                     protected override bool TryDequeue(out Action unit) {
                         if (m_queue.TryDequeue(out unit)) {
                             Interlocked.Decrement(ref m_queueLength);
                             return true;
                         }
                         return false;
                     }
                     protected override bool Suspend() {
                         // This override solves race condition
                         // WORKER                   CLIENT
                         // ---------------------------------------
                         // TryDeque == false
                         //                          Enqueue(unit), queueLen++
                         //                          GrowPool? == NO
                         // ActiveThreads--
                         // Suspend
                         //    queueLength > 0
                         // continue
+                        Thread.MemoryBarrier();
                         if (m_queueLength > 0)
                             return true;
+                        Interlocked.Decrement(ref m_workers);
                         return base.Suspend();
                     }
                     protected override void InvokeUnit(Action unit) {
                         unit();
                     }
                 }
             }

Implab/Promise.cs +3 -1

             using System;
             using System.Collections.Generic;
             using System.Reflection;
             using System.Diagnostics;
             using System.Threading;
             using Implab.Parallels;
             namespace Implab {
                 public delegate void ErrorHandler(Exception e);
                 public delegate T ErrorHandler<out T>(Exception e);
                 public delegate void ResultHandler<in T>(T result);
                 public delegate TNew ResultMapper<in TSrc,out TNew>(TSrc result);
                 /// <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 ResultHandler<T> resultHandler;
                         public ErrorHandler<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;
                     readonly bool m_cancellable;
                     int m_childrenCount = 0;
                     int m_state;
                     T m_result;
                     Exception m_error;
                     readonly MTQueue<HandlerDescriptor> m_handlers = new MTQueue<HandlerDescriptor>();
                     public Promise() {
                         m_cancellable = true;
                     }
                     public Promise(IPromise parent, bool cancellable) {
                         m_cancellable = cancellable;
                         if (parent != null)
                             AddHandler(
                                 null,
                                 null,
                                 () => {
                                     if (parent.IsExclusive)
                                         parent.Cancel();
                                 },
                                 null
                             );
                     }
                     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) {
-                            /* noop */
+                            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;
                             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 (m_cancellable && BeginTransit()) {
                             CompleteTransit(CANCELLED_STATE);
                             OnStateChanged();
                         }
                     }
                     public IPromise<T> Then(ResultHandler<T> success, ErrorHandler<T> error, Action cancel) {
                         if (success == null && error == null && cancel == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(success, error, cancel, medium);
                         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(ResultHandler<T> success, ErrorHandler<T> error) {
                         if (success == null && error == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(success, error, null, medium);
                         return medium;
                     }
                     public IPromise<T> Then(ResultHandler<T> success) {
                         if (success == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(success, null, null, medium);
                         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(ResultHandler<T> success, ErrorHandler error, Action cancel) {
                         if (success == null && error == null && cancel == null)
                             return;
                         ErrorHandler<T> errorHandler = null;
                         if (error != null)
                             errorHandler = err => {
                                 error(err);
                                 return default(T);
                             };
                         AddHandler(success, errorHandler, cancel, null);
                     }
                     public void Last(ResultHandler<T> success, ErrorHandler error) {
                         Last(success, error, null);
                     }
                     public void Last(ResultHandler<T> success) {
                         Last(success, null, null);
                     }
                     public IPromise Error(ErrorHandler error) {
                         if (error == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(
                             null,
                             e => {
                                 error(e);
                                 return default(T);
                             },
                             null,
                             medium
                         );
                         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(ErrorHandler<T> handler) {
                         if (handler == null)
                             return this;
                         var medium = new Promise<T>(this, true);
                         AddHandler(null, handler, null, medium);
                         return medium;
                     }
                     /// <summary>
                     /// Позволяет преобразовать результат выполения операции к новому типу.
                     /// </summary>
                     /// <typeparam name="TNew">Новый тип результата.</typeparam>
                     /// <param name="mapper">Преобразование результата к новому типу.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено при выполнении исходного обещания.</returns>
                     public IPromise<TNew> Then<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler<TNew> error, Action cancel) {
                         Safe.ArgumentNotNull(mapper, "mapper");
                         // создаем прицепленное обещание
                         var medium = new Promise<TNew>(this, true);
                         ResultHandler<T> resultHandler = result => medium.Resolve(mapper(result));
                         ErrorHandler<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
                         );
                         return medium;
                     }
                     public IPromise<TNew> Then<TNew>(ResultMapper<T, TNew> mapper, ErrorHandler<TNew> error) {
                         return Then(mapper, error, null);
                     }
                     public IPromise<TNew> Then<TNew>(ResultMapper<T, TNew> mapper) {
                         return Then(mapper, null, null);
                     }
                     /// <summary>
                     /// Сцепляет несколько аснхронных операций. Указанная асинхронная операция будет вызвана после
                     /// выполнения текущей, а результат текущей операции может быть использован для инициализации
                     /// новой операции.
                     /// </summary>
                     /// <typeparam name="TNew">Тип результата указанной асинхронной операции.</typeparam>
                     /// <param name="chained">Асинхронная операция, которая должна будет начаться после выполнения текущей.</param>
                     /// <param name="error">Обработчик ошибки. Данный обработчик получит
                     /// исключение возникшее при выполнении текуещй операции.</param>
                     /// <returns>Новое обещание, которое будет выполнено по окончанию указанной аснхронной операции.</returns>
                     public IPromise<TNew> Chain<TNew>(ResultMapper<T, IPromise<TNew>> chained, ErrorHandler<IPromise<TNew>> error, Action cancel) {
                         Safe.ArgumentNotNull(chained, "chained");
                         // проблема в том, что на момент связывания еще не начата асинхронная операция, поэтому нужно
                         // создать посредника, к которому будут подвызяваться следующие обработчики.
                         // когда будет выполнена реальная асинхронная операция, она обратиться к посреднику, чтобы
                         // передать через него результаты работы.
                         var medium = new Promise<TNew>(this, true);
                         ResultHandler<T> resultHandler = delegate(T result) {
                             if (medium.IsCancelled)
                                 return;
                             var promise = chained(result);
                             promise.Last(
                                 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();
                             });
                         };
                         ErrorHandler<T> errorHandler;
                         if (error != null)
                             errorHandler = delegate(Exception e) {
                                 try {
                                     var promise = error(e);
                                     promise.Last(
                                         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
                         );
                         return medium;
                     }
                     public IPromise<TNew> Chain<TNew>(ResultMapper<T, IPromise<TNew>> chained, ErrorHandler<IPromise<TNew>> error) {
                         return Chain(chained, error, null);
                     }
                     public IPromise<TNew> Chain<TNew>(ResultMapper<T, IPromise<TNew>> chained) {
                         return Chain(chained, null, null);
                     }
                     public IPromise<T> Cancelled(Action handler) {
                         var medium = new Promise<T>(this,true);
                         AddHandler(null, null, handler, medium);
                         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");
                         AddHandler(
                             x => handler(),
                             e => {
                                 handler();
                                 throw new TransientPromiseException(e);
                             },
                             handler,
                             null
                         );
                         return this;
                     }
                     /// <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(ResultHandler<T> success, ErrorHandler<T> error, Action cancel, Promise<T> medium) {
                         if (success != null || error != null)
                             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, ErrorHandler error, Action cancel) {
                         return Then(
                             x => success(),
                             e => {
                                 error(e);
                                 return default(T);
                             },
                             cancel
                         );
                     }
                     IPromise IPromise.Then(Action success, ErrorHandler error) {
                         return Then(
                             x => success(),
                             e => {
                                 error(e);
                                 return default(T);
                             }
                         );
                     }
                     IPromise IPromise.Then(Action success) {
                         return Then(x => success());
                     }
                     void IPromise.Last(Action success, ErrorHandler error, Action cancel) {
                         Last(x => success(), error, cancel);
                     }
                     void IPromise.Last(Action success, ErrorHandler error) {
                         Last(x => success(), error, null);
                     }
                     void IPromise.Last(Action success) {
                         Last(x => success(), null, null);
                     }
                     IPromise IPromise.Error(ErrorHandler 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
                 }
             }

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