首页 > 解决方案 > c# Immutability 创建全局存储

问题描述

对于我的项目,我正在尝试创建一个全局存储来服务于这样的可变状态:

  // Immutable program state
  sealed public class State : IEquatable<State> {
    public State(ClientsConnections clientsConnections, ImmutableList<string> ids) {
      this.ClientsConnections = clientsConnections;
      this.Ids = ids;
    }

    public readonly ClientsConnections ClientsConnections; // ClientsConnections is immutable
    public readonly ImmutableList<string> Ids; // also immutable

    public override int GetHashCode() => HashCode.Combine(AgentsConnections.GetHashCode(), Ids.GetHashCode());
    public override bool Equals(object obj) { var o = obj as State; return o is null ? false : ClientsConnections.Equals(o.ClientsConnections) && Ids.Equals(Ids); }
    public bool Equals(State o) => object.Equals(this, o); 
    public static bool operator ==(State o1, State o2) => object.Equals(o1, o2); 
    public static bool operator !=(State o1, State o2) => !object.Equals(o1, o2);
  }

  // Store is a mutable singleton
  sealed public class Store {
    readonly object stateLock = new object();

    public Store() => this.State = new State(new ClientsConnections(), ImmutableList<string>.Empty);

    public State State { get; private set; }
    public void SetState(Func<State, State> f) { lock (stateLock) State = f(State); }
  }

然后我在这样的代码中使用它:

Thread1 - f1() { 
  var currState=Store.State; 
  log(currState.ids);
}

Thread2 - f2() { 
  Store.SetState(currState => {
    var newids = currState.Ids.Add("hello");
    return new State(currState.ClientsConnections, newids);
  });
}

问题:

  1. 这个代码线程安全吗?特别是我需要锁定 Store.State getter 吗?我的理由是,由于 getter 执行了按值复制状态引用的原子分配,那么我不需要在这里锁定它吗?

  2. 我可以/应该在这里使用 ImmutableInterlocked 吗?

标签: c#c#-7.0

解决方案


这个代码线程安全吗?特别是我需要锁定 Store.State getter 吗?我的理由是,由于 getter 执行了按值复制状态引用的原子分配,那么我不需要在这里锁定它吗?

只要您对陈旧的数据感到满意,是的,它会正常工作。

我可以/应该在这里使用 ImmutableInterlocked 吗?

是的,我认为你应该(但你应该配置文件以确认它是否真的提供了好处)。ImmutableInterlocked.Update是我的建议。


推荐阅读