implab/ImplabNet Commit - r129:471f596b2603

Added SharedLock to synchronization routines

cin -

r129:471f596b2603 v2

parent child

Context file:

r129:471f596b2603

Implab/Parallels/SharedLock.cs created 644 +75 0

@@ -0,0 +1,75
	1	using System;
	2	using System.Threading;
	3	using System.Diagnostics;
	4
	5	namespace Implab.Parallels {
	6	/// <summary>
	7	/// Implements a lightweight mechanism to aquire a shared or an exclusive lock.
	8	/// </summary>
	9	public class SharedLock {
	10	readonly object m_lock = new object();
	11	int m_locks;
	12	bool m_exclusive;
	13
	14	public bool LockExclusive(int timeout) {
	15	lock (m_lock) {
	16	if (m_locks > 0 && !Monitor.Wait(m_lock, timeout))
	17	return false;
	18	m_exclusive = true;
	19	m_locks = 1;
	20	}
	21	}
	22
	23	public void LockExclusive() {
	24	LockExclusive(-1);
	25	}
	26
	27	public bool LockShared(int timeout) {
	28	lock (m_lock) {
	29	if (!m_exclusive) {
	30	m_locks++;
	31	return true;
	32	}
	33
	34	if (m_lock == 0) {
	35	m_exclusive = false;
	36	m_locks = 1;
	37	return true;
	38	}
	39
	40	if (Monitor.Wait(m_lock, timeout)) {
	41	Debug.Assert(m_locks == 0);
	42	m_locks = 1;
	43	m_exclusive = false;
	44	return true;
	45	}
	46	return false;
	47	}
	48	}
	49
	50	public void LockShared() {
	51	LockShared(-1);
	52	}
	53
	54	public void ReleaseShared() {
	55	lock (m_lock) {
	56	if (m_exclusive \|\| m_locks <= 0)
	57	throw new InvalidOperationException();
	58	m_locks--;
	59	if (m_locks == 0)
	60	Monitor.PulseAll(m_lock);
	61	}
	62	}
	63
	64	public void ReleaseExclusive() {
	65	lock (m_lock) {
	66	if (!m_exclusive && m_locks != 1)
	67	throw new InvalidOperationException();
	68	m_locks = 0;
	69	Monitor.PulseAll(m_lock);
	70	}
	71	}
	72
	73	}
	74	}
	75

Implab/Implab.csproj +1 -2

                 <Compile Include="Diagnostics\Extensions.cs" />
                 <Compile Include="IComponentContainer.cs" />
                 <Compile Include="PromiseEventType.cs" />
-                <Compile Include="Parallels\MTCustomQueue.cs" />
-                <Compile Include="Parallels\MTCustomQueueNode.cs" />
                 <Compile Include="ComponentContainer.cs" />
                 <Compile Include="DisposablePool.cs" />
                 <Compile Include="ObjectPool.cs" />
                 <Compile Include="Promise.cs" />
                 <Compile Include="PromiseTransientException.cs" />
                 <Compile Include="Parallels\Signal.cs" />
+                <Compile Include="Parallels\SharedLock.cs" />
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <ItemGroup />

Implab/Parallels/AsyncQueue.cs +3 -3

                         #region ICollection implementation
                         public void Add(T item) {
-                            throw new InvalidOperationException();
+                            throw new NotSupportedException();
                         }
                         public void Clear() {
-                            throw new InvalidOperationException();
+                            throw new NotSupportedException();
                         }
                         public bool Contains(T item) {
                         }
                         public bool Remove(T item) {
-                            throw new NotImplementedException();
+                            throw new NotSupportedException();
                         }
                         public int Count {

Implab/Parallels/Signal.cs +1 -1

             namespace Implab.Parallels {
                 /// <summary>
-                /// Implements simple signalling logic using <see cref="Monitor.PulseAll(object)"/>.
+                /// Implements a simple signalling logic using <see cref="Monitor.PulseAll(object)"/>.
                 /// </summary>
                 public class Signal {
                     readonly object m_lock = new object();

Implab/Parallels/WorkerPool.cs +2 -2

                 public class WorkerPool : DispatchPool<Action> {
                     AsyncQueue<Action> m_queue = new AsyncQueue<Action>();
-                    int m_queueLength = 0;
+                    int m_queueLength;
                     readonly int m_threshold = 1;
                     public WorkerPool(int minThreads, int maxThreads, int threshold)
                         var lop = TraceContext.Instance.CurrentOperation;
-                        EnqueueTask(delegate() {
+                        EnqueueTask(delegate {
                             TraceContext.Instance.EnterLogicalOperation(lop, false);
                             try {
                                 promise.Resolve(task());

Implab/Parallels/MTCustomQueue.cs removed 0 -135

NO CONTENT: file was removed

Implab/Parallels/MTCustomQueueNode.cs removed 0 -6

NO CONTENT: file was removed

General Comments 0

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

No TODOs yet

	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