DataTable快速人口答案

【问题标题】：DataTable rapid populationDataTable快速人口
【发布时间】：2015-07-14 10:12:51
【问题描述】：

美好的一天！

我有一个多线程应用程序，一般来说，它的目的是处理一个非常快速填充的消息队列。消息由一个线程添加到队列中，另一个线程处理它们。

在处理线程中，一些消息必须显示在网格中。 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(){} 运算符上更改 Mutex 对象。这对我没有帮助。我尝试在 BindingList 上更改 DataTable。这对我没有帮助。我可以通过创建全局变量 private readonly int[] LastAddedStation = new int[3]; 来减少表中的重复次数；并在 if 块中添加这样的表达式 (if (Continue){}): LastAddedStation[0] != SID || LastAddedStation[1] != NID || LastAddedStation[2] != 出价。它帮助我降低了表中的重复次数，但在我看来，这是“气味”。有什么明确的方法可以帮助解决我的情况吗？

我做错了什么？使用 DataTables 进行高负载工作的最佳实践是什么？

附：对不起我的英语，我不是母语人士。

【问题讨论】：

标签： c# multithreading datatable population

【解决方案1】：

主要是这里回答-What is the difference between SynchronizationContext.Send and SynchronizationContext.Post?。

Post 方法在异步模式下工作 - “放下并继续”。所以似乎 post 方法中的下一次迭代代码还没有完成。

我选择添加一个单独的计数器来计算添加的行数并使用 DataTable.Count 进行检查。

【讨论】：