Merge pull request #4 from ShawnLaMountain/main

Added DictionaryThreadSafe object
ThunderDesign · Feb 19, 2022 · c28b34c · c28b34c
2 parents b1b8907 + af6efef
commit c28b34c
Show file tree

Hide file tree

Showing 4 changed files with 273 additions and 202 deletions.
diff --git a/src/ThunderDesign.Net-PCL.Threading/Collections/DictionaryThreadSafe.cs b/src/ThunderDesign.Net-PCL.Threading/Collections/DictionaryThreadSafe.cs
@@ -0,0 +1,242 @@
+using System;
+using System.Collections.Generic;
+using System.Runtime.Serialization;
+using System.Text;
+using ThunderDesign.Net.Threading.Interfaces;
+using ThunderDesign.Net.Threading.Threading;
+
+namespace ThunderDesign.Net.Threading.Collections
+{
+    public class DictionaryThreadSafe<TKey, TValue> : Dictionary<TKey, TValue>, IDictionaryThreadSafe<TKey, TValue>
+    {
+        #region constructors
+        public DictionaryThreadSafe() : base() { }
+        public DictionaryThreadSafe(int capacity) : base(capacity) { }
+        public DictionaryThreadSafe(IEqualityComparer<TKey> comparer) : base(comparer) { }
+        public DictionaryThreadSafe(IDictionary<TKey, TValue> dictionary) : base(dictionary) { }
+        public DictionaryThreadSafe(int capacity, IEqualityComparer<TKey> comparer) : base(capacity, comparer) { }
+        public DictionaryThreadSafe(IDictionary<TKey, TValue> dictionary, IEqualityComparer<TKey> comparer) : base(dictionary, comparer) { }
+        #endregion
+
+        #region properties
+        public new IEqualityComparer<TKey> Comparer
+        {
+            get
+            {
+                _ReaderWriterNotifyLock.EnterReadLock();
+                try
+                {
+                    return base.Comparer;
+                }
+                finally
+                {
+                    _ReaderWriterNotifyLock.ExitReadLock();
+                }
+            }
+        }
+
+        public new int Count
+        {
+            get
+            {
+                _ReaderWriterNotifyLock.EnterReadLock();
+                try
+                {
+                    return base.Count;
+                }
+                finally
+                {
+                    _ReaderWriterNotifyLock.ExitReadLock();
+                }
+            }
+        }
+
+        public new KeyCollection Keys
+        {
+            get
+            {
+                _ReaderWriterNotifyLock.EnterReadLock();
+                try
+                {
+                    return base.Keys;
+                }
+                finally
+                {
+                    _ReaderWriterNotifyLock.ExitReadLock();
+                }
+            }
+        }
+
+        public new ValueCollection Values
+        {
+            get
+            {
+                _ReaderWriterNotifyLock.EnterReadLock();
+                try
+                {
+                    return base.Values;
+                }
+                finally
+                {
+                    _ReaderWriterNotifyLock.ExitReadLock();
+                }
+            }
+        }
+
+        public new TValue this[TKey key]
+        {
+            get
+            {
+                _ReaderWriterNotifyLock.EnterReadLock();
+                try
+                {
+                    return base[key];
+                }
+                finally
+                {
+                    _ReaderWriterNotifyLock.ExitReadLock();
+                }
+            }
+            set
+            {
+                _ReaderWriterNotifyLock.EnterWriteLock();
+                try
+                {
+                    base[key] = value;
+                }
+                finally
+                {
+                    _ReaderWriterNotifyLock.ExitWriteLock();
+                }
+            }
+        }
+        #endregion
+
+        #region methods
+        public new virtual void Add(TKey key, TValue value)
+        {
+            _ReaderWriterNotifyLock.EnterWriteLock();
+            try
+            {
+                base.Add(key, value);
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitWriteLock();
+            }
+        }
+
+        public new virtual void Clear()
+        {
+            _ReaderWriterNotifyLock.EnterWriteLock();
+            try
+            {
+                base.Clear();
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitWriteLock();
+            }
+        }
+
+        public new bool ContainsKey(TKey key)
+        {
+            _ReaderWriterNotifyLock.EnterReadLock();
+            try
+            {
+                return base.ContainsKey(key);
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitReadLock();
+            }
+        }
+
+        public new bool ContainsValue(TValue value)
+        {
+            _ReaderWriterNotifyLock.EnterReadLock();
+            try
+            {
+                return base.ContainsValue(value);
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitReadLock();
+            }
+        }
+
+        public new Enumerator GetEnumerator()
+        {
+            _ReaderWriterNotifyLock.EnterReadLock();
+            try
+            {
+                return base.GetEnumerator();
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitReadLock();
+            }
+        }
+
+        [System.Security.SecurityCritical]  // auto-generated_required
+        public override void GetObjectData(SerializationInfo info, StreamingContext context)
+        {
+            _ReaderWriterNotifyLock.EnterReadLock();
+            try
+            {
+                base.GetObjectData(info, context);
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitReadLock();
+            }
+        }
+
+        public override void OnDeserialization(Object sender)
+        {
+            _ReaderWriterNotifyLock.EnterReadLock();
+            try
+            {
+                base.OnDeserialization(sender);
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitReadLock();
+            }
+        }
+
+        public new virtual bool Remove(TKey key)
+        {
+            bool result = false;
+            _ReaderWriterNotifyLock.EnterWriteLock();
+            try
+            {
+                result = base.Remove(key);
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitWriteLock();
+            }
+            return result;
+        }
+
+        public new bool TryGetValue(TKey key, out TValue value)
+        {
+            _ReaderWriterNotifyLock.EnterReadLock();
+            try
+            {
+                return base.TryGetValue(key, out value);
+            }
+            finally
+            {
+                _ReaderWriterNotifyLock.ExitReadLock();
+            }
+        }
+        #endregion
+
+        #region variables
+        protected static readonly ReaderWriterNotifyLock _ReaderWriterNotifyLock = new ReaderWriterNotifyLock();
+
+        #endregion
+    }
+}