ThreadSafeStore<TKey, TValue>
using System;
using System.Collections.Concurrent;
using System.Runtime.CompilerServices;
namespace Newtonsoft.Json.Utilities
{
[System.Runtime.CompilerServices.NullableContext(1)]
[System.Runtime.CompilerServices.Nullable(0)]
internal class ThreadSafeStore<TKey, [System.Runtime.CompilerServices.Nullable(2)] TValue>
{
private readonly ConcurrentDictionary<TKey, TValue> _concurrentStore;
private readonly Func<TKey, TValue> _creator;
public ThreadSafeStore(Func<TKey, TValue> creator)
{
ValidationUtils.ArgumentNotNull(creator, "creator");
_creator = creator;
_concurrentStore = new ConcurrentDictionary<TKey, TValue>();
}
public TValue Get(TKey key)
{
return _concurrentStore.GetOrAdd(key, _creator);
}
}
}