再会！
我有一个多线程应用程序，一般来说，它的目的是处理一个非常快速的填充消息队列。消息由一个线程添加到队列中，另一个线程处理它们。
在处理线程中，一些消息必须显示在网格中。Grid 的DataSource 是DataTable。处理线程与 DataTable 一起工作（在每个消息处理上；NID、SID、BID - 是 1 条消息的一部分）：
Lockers[5].WaitOne();
Continue = true;
for (int i = 0; i <= mDataSource.Tables["Stations"].Rows.Count - 1; i++)
{
DataRow Current = mDataSource.Tables["Stations"].Rows[i];
if ((ushort)Current["SID"] == SID &&
(ushort)Current["NID"] == NID &&
(ushort)Current["BID"] == BID)
{
Continue = false;
break;
}
}
if (Continue &&)
{
SyncContext.Post(x =>
{
mDataSource.Tables["Stations"].BeginLoadData();
mDataSource.Tables["Stations"].Rows.Add(
(fbn + 1) * 10 + 1 + dn,
DeviceList[fbn].Main.Receivers[dn].Channel,
DeviceList[fbn].Main.Receivers[dn].Pilot, SID, NID, BID,
DeviceList[fbn].Receivers[dn].MCC, Latitude, Longitude);
mDataSource.Tables["Stations"].EndLoadData();
},
null);
}
Lockers[5].ReleaseMutex();
Lockers[5] - 互斥对象，mDataSource - 数据集对象。SynContext - 是主应用程序表单的同步上下文。正如我上面所说的消息队列的填充速度非常快，所以这段代码在运行时 1 秒内触发了大约 500 次。并且在消息队列中可能会重复，所以我不能显示它们。问题是在消息处理线程的几次第一次迭代中，我得到 mDataSource.Tables["Stations"].Rows.Count = 0，因此我的 Continue 变量 = true 并且我的表中有重复。在接下来的迭代中，我还在日志中看到表中添加了行，但 Count 可能仍为 2（但在日志中添加了 17 行）。为什么会这样？
我尝试在 lock(){} 运算符上更改互斥对象。这对我没有帮助。我尝试在 BindingList 上更改 DataTable。这对我没有帮助。我可以通过创建全局变量 private readonly int[] LastAddedStation = new int[3]; 来降低表中的重复次数；并在 if 块中添加这样的表达式 (if (Continue){}): LastAddedStation[0] != SID || LastAddedStation[1] != NID || LastAddedStation[2] != 出价。它帮助我降低了表中的重复次数，但在我看来，这是“气味”。有什么明确的方法可以帮助我的情况吗？
我做错了什么？使用 DataTables 进行高负载工作的最佳实践是什么？
PS对不起我的英语，我不是母语人士。