数据行锁定分配

本文关键字:分配 锁定 数据 | 更新日期: 2023-09-27 18:33:07

我有一个巨大的Parallel.For循环。问题是 DataRow 写入操作不是多线程的,所以我需要锁定分配语句。这对我来说不是问题,除了当我必须锁定所有赋值操作时它看起来很丑。它看起来像这样:

Parallel.For(0, ds.Tables["MyTable"].Rows.Count, i =>
lock (s_lockObject)
{
    ds.Tables["MyTable"].Rows[i]["myValue1"] = myValue1;
}
//some operations
lock (s_lockObject)
{
    ds.Tables["MyTable"].Rows[i]["myValue2"] = myValue2;
}
//some operations
lock (s_lockObject)
{
    ds.Tables["MyTable"].Rows[i]["myValue3"] = myValue3;
}
});

也许有一种方法可以默认锁定分配,例如编写一些扩展。

数据行锁定分配

如果你想摆脱重复的代码,你可以为赋值 DataRow 值提取一个函数。例如:

    public static class DataTableExtensions
    {
        public static void SetCellValue<T>(this DataTable table, int row, string col, T value)
        {
           lock (table)
           {
              table.Rows[row][col] = value;
           }
        }
    }