-
Notifications
You must be signed in to change notification settings - Fork 35
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add execution synchronized LazyDictionary implementation
- Loading branch information
Showing
3 changed files
with
178 additions
and
4 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,110 @@ | ||
| using System; | ||
| using System.Collections; | ||
| using System.Collections.Concurrent; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using System.Threading; | ||
|
|
||
| using CodeJam.Collections; | ||
|
|
||
| using JetBrains.Annotations; | ||
|
|
||
| namespace CodeJam.Threading | ||
| { | ||
| /// <summary> | ||
| /// Dictionary with lazy values initialization. | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// Thread safe. | ||
| /// </remarks> | ||
| [PublicAPI] | ||
| public class ExecSyncConcurrentLazyDictionary<TKey, TValue> : ILazyDictionary<TKey, TValue> | ||
| { | ||
| private readonly Func<TKey, TValue> _valueFactory; | ||
| private readonly IEqualityComparer<TKey> _comparer; | ||
| private readonly ConcurrentDictionary<TKey, Lazy<TValue>> _map; | ||
|
|
||
| /// <summary> | ||
| /// Initialize instance. | ||
| /// </summary> | ||
| /// <param name="valueFactory">Function to create value on demand.</param> | ||
| /// <param name="comparer">Key comparer.</param> | ||
| public ExecSyncConcurrentLazyDictionary([NotNull] Func<TKey, TValue> valueFactory, IEqualityComparer<TKey> comparer) | ||
| { | ||
| if (valueFactory == null) throw new ArgumentNullException(nameof(valueFactory)); | ||
| _valueFactory = valueFactory; | ||
| _comparer = comparer; | ||
| _map = new ConcurrentDictionary<TKey, Lazy<TValue>>(comparer); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Initialize instance. | ||
| /// </summary> | ||
| /// <param name="valueFactory">Function to create value on demand.</param> | ||
| public ExecSyncConcurrentLazyDictionary([NotNull] Func<TKey, TValue> valueFactory) | ||
| : this(valueFactory, EqualityComparer<TKey>.Default) | ||
| { } | ||
|
|
||
| /// <summary> | ||
| /// Clears all created values | ||
| /// </summary> | ||
| public void Clear() => _map.Clear(); | ||
|
|
||
| #region Implementation of IEnumerable | ||
| IEnumerator<KeyValuePair<TKey, TValue>> IEnumerable<KeyValuePair<TKey, TValue>>.GetEnumerator() => | ||
| _map | ||
| .Select(v => new KeyValuePair<TKey, TValue>(v.Key, v.Value.Value)) | ||
| .GetEnumerator(); | ||
|
|
||
| IEnumerator IEnumerable.GetEnumerator() => ((IEnumerable<KeyValuePair<TKey, TValue>>)this).GetEnumerator(); | ||
| #endregion | ||
|
|
||
| #region Implementation of IReadOnlyCollection<out KeyValuePair<TKey,TValue>> | ||
| int IReadOnlyCollection<KeyValuePair<TKey, TValue>>.Count => _map.Count; | ||
| #endregion | ||
|
|
||
| #region Implementation of IReadOnlyDictionary<TKey,TValue> | ||
| /// <summary>Determines whether the read-only dictionary contains an element that has the specified key.</summary> | ||
| /// <returns>true if the read-only dictionary contains an element that has the specified key; otherwise, false.</returns> | ||
| /// <param name="key">The key to locate.</param> | ||
| /// <exception cref="T:System.ArgumentNullException"> | ||
| /// <paramref name="key" /> is null.</exception> | ||
| public bool ContainsKey(TKey key) => _map.ContainsKey(key); | ||
|
|
||
| /// <summary>Gets the value that is associated with the specified key.</summary> | ||
| /// <returns>true if the object that implements the <see cref="T:System.Collections.Generic.IReadOnlyDictionary`2" /> interface contains an element that has the specified key; otherwise, false.</returns> | ||
| /// <param name="key">The key to locate.</param> | ||
| /// <param name="value">When this method returns, the value associated with the specified key, if the key is found; otherwise, the default value for the type of the <paramref name="value" /> parameter. This parameter is passed uninitialized.</param> | ||
| /// <exception cref="T:System.ArgumentNullException"> | ||
| /// <paramref name="key" /> is null.</exception> | ||
| public bool TryGetValue(TKey key, out TValue value) | ||
| { | ||
| Lazy<TValue> lv; | ||
| var res = _map.TryGetValue(key, out lv); | ||
| value = res ? lv.Value : default(TValue); | ||
| return res; | ||
| } | ||
|
|
||
| /// <summary>Gets the element that has the specified key in the read-only dictionary.</summary> | ||
| /// <returns>The element that has the specified key in the read-only dictionary.</returns> | ||
| /// <param name="key">The key to locate.</param> | ||
| /// <exception cref="T:System.ArgumentNullException"> | ||
| /// <paramref name="key" /> is null.</exception> | ||
| /// <exception cref="T:System.Collections.Generic.KeyNotFoundException">The property is retrieved and <paramref name="key" /> is not found. </exception> | ||
| public TValue this[TKey key] => | ||
| _map | ||
| .GetOrAdd( | ||
| key, | ||
| new Lazy<TValue>(() => _valueFactory(key), LazyThreadSafetyMode.ExecutionAndPublication)) | ||
| .Value; | ||
|
|
||
| /// <summary>Gets an enumerable collection that contains the keys in the read-only dictionary. </summary> | ||
| /// <returns>An enumerable collection that contains the keys in the read-only dictionary.</returns> | ||
| public IEnumerable<TKey> Keys => _map.Keys; | ||
|
|
||
| /// <summary>Gets an enumerable collection that contains the values in the read-only dictionary.</summary> | ||
| /// <returns>An enumerable collection that contains the values in the read-only dictionary.</returns> | ||
| public IEnumerable<TValue> Values => _map.Values.Select(lv => lv.Value); | ||
| #endregion | ||
| } | ||
| } |