0

私が書いたいくつかのコードで奇妙な並行性の問題が発生しています。最初に尋ねるのは、なぜCFを使用してDbModelBuilderを使用しているのかということです...まあ、すべて同一のデータベースをN番目に持つことができ、データの分離を維持する必要がある状況があります。私はCFを使用して、複数の開発者がGUIを使用してモデルをだましているという大規模なモデル生成の問題を防ぎます。悲しいかな、これは私がやっていることの基本的なコードです。

2つのコンソール書き込みラインはヒットしないはずですが、ヒットします。

これを試して、問題がどこにあるか教えていただけますか？

これは、テストハーネスコンソールアプリです。

class Program
{
    static void Main(string[] args)
    {
        for (int i = 0; i < 100; i++)
        {
            var workerObject = new Worker();
            var workerThread = new Thread(workerObject.DoWork);
            workerThread.Start();
        }
    }
}

public class Worker
{
    public void DoWork()
    {
        var connections = new List<KeyValuePair<string, DynamicDb>>
            {
                new KeyValuePair<string, DynamicDb>("db1", new MyDynamicEntityLayer("db1").DynamicDb()),
                new KeyValuePair<string, DynamicDb>("db2", new MyDynamicEntityLayer("db2").DynamicDb())
            };

        foreach (var db in connections)
        {
            if (db.Key == "db1" && db.Value.ConnectionString.Contains("db2"))
                Console.WriteLine("THIS SHOULD NEVER HAPPEN!!! db1 : " + db.Value.ConnectionString);
            if (db.Key == "db2" && db.Value.ConnectionString.Contains("db1"))
                Console.WriteLine("THIS SHOULD NEVER HAPPEN!!! db2 : " + db.Value.ConnectionString);
        }
    }
}

エンティティクラスは次のとおりです。

public class MyDynamicEntityLayer
{
    public static string ConnectionString { get; set; }
    public MyDynamicEntityLayer(string db = null)
    {
        MakeAConnectionString(db);
        Database.SetInitializer<DynamicDb>(null);
    }

    public void MakeAConnectionString(string db)
    {
        var sqlBuilder = new SqlConnectionStringBuilder();
        if (db == "db1")
        {
            sqlBuilder.DataSource = "MySqlServer";
            sqlBuilder.InitialCatalog = "db1";
            sqlBuilder.ConnectTimeout = 180;
            sqlBuilder.IntegratedSecurity = true;
        }
        else
        {
            sqlBuilder.DataSource = "MySqlServer";
            sqlBuilder.InitialCatalog = "db2";
            sqlBuilder.ConnectTimeout = 180;
            sqlBuilder.IntegratedSecurity = true;
        }

        ConnectionString = sqlBuilder.ToString();
    }

    public DynamicDb DynamicDb()
    {
        var builder = new DbModelBuilder(DbModelBuilderVersion.Latest);
        TableMappingToBuilder(builder);
        var compiled = builder.Build(Database.DefaultConnectionFactory.CreateConnection(ConnectionString)).Compile();
        return new DynamicDb(compiled);
    }

    public void TableMappingToBuilder(DbModelBuilder builder)
    {
        builder.Configurations.Add(new EntityTypeConfiguration<ConcurrencyTest>());
        builder.Entity<ConcurrencyTest>().ToTable("ConcurrencyTest", "dbo");
    }
}

と私のDbContextCSファイル：

public class DynamicDb : DbContext
{
    public string ConnectionString { get; set; }
    public DynamicDb(DbCompiledModel model)
        : base(MyDynamicEntityLayer.ConnectionString, model)
    {
        ConnectionString = MyDynamicEntityLayer.ConnectionString;
        ((IObjectContextAdapter)this).ObjectContext.CommandTimeout = 100;
    }
    public DbSet<ConcurrencyTest> ConcurrencyTests { get; set; }
}

public class ConcurrencyTest
{
    public int ID { get; set; }
    public string MyColumn { get; set; }
}
4

1 に答える 1

1

あなたの問題は：

public class MyDynamicEntityLayer
{
    public static string ConnectionString { get; set; } // STATIC PROPERTY
    ...

}

すべてのワーカースレッドは、このプロパティに格納されている単一の値を共有し、その変更を求めて戦います。

于 2012-09-24T18:03:34.040 に答える