1
1

CallContext.cs 629 B

123456789101112131415161718
  1. using System.Collections.Concurrent;
  2. using System.Threading;
  3. namespace Masuit.Tools.NoSQL.MongoDBClient
  4. {
  5. /// <summary>
  6. /// 取线程内唯一对象
  7. /// </summary>
  8. /// <typeparam name="T"></typeparam>
  9. static class CallContext<T>
  10. {
  11. static ConcurrentDictionary<string, AsyncLocal<T>> state = new ConcurrentDictionary<string, AsyncLocal<T>>();
  12. public static void SetData(string name, T data) => state.GetOrAdd(name, _ => new AsyncLocal<T>()).Value = data;
  13. public static T GetData(string name) => state.TryGetValue(name, out AsyncLocal<T> data) ? data.Value : default(T);
  14. }
  15. }