c# - 将记录插入到 SQL Server CE 数据库移动到另一个线程？ C# Compact Framework 3.5

Question

我在尝试将一段代码放入另一个线程以提高性能时遇到了一些麻烦。

我在下面有以下代码(添加线程和注释)，我在其中解析大型 XML 文件(最终目标 100,000 行)，然后将其写入 SQL Server CE 3.5 数据库文件(.sdf ) 使用记录和插入 (SqlCeResultSet/SqlCeUpdatableRecord)。

while循环中if语句中的两行代码，

xElem = (XElement)XNode.ReadFrom(xmlTextReader);

和

rs.Insert(record);

执行所需的时间大致相同。我正在考虑在解析下一行 xml 文件时运行 rs.Insert(record);。但是，我仍然无法使用 Thread 或 ThreadPool 来完成它。

我必须确保在现有线程中完成执行 rs.Insert(record); 之前，传递给线程的记录不会更改。因此，我尝试在写入新记录 (record.SetValue(i, values[i]);) 之前放置 thread.Join()，但是当我尝试运行程序时仍然遇到冲突 -由于多次尝试写入相同的行(尤其是对于索引)，程序因一堆错误而崩溃。

谁能帮我提点建议？如何将 rs.Insert(record); 移动到另一个线程以提高性能？

XmlTextReader xmlTextReader = new XmlTextReader(modFunctions.InFName);
XElement xElem = new XElement("item");

using (SqlCeConnection cn = new SqlCeConnection(connectionString))
{
    if (cn.State == ConnectionState.Closed)
        cn.Open();

    using (SqlCeCommand cmd = new SqlCeCommand())
    {
        cmd.Connection = cn;
        cmd.CommandText = "item";
        cmd.CommandType = CommandType.TableDirect;

        using (SqlCeResultSet rs = cmd.ExecuteResultSet(ResultSetOptions.Updatable))
        {
            SqlCeUpdatableRecord record = rs.CreateRecord();

            // Thread code addition
            Thread t = new Thread(new ThreadStart(() => rs.Insert(record));

            while (xmlTextReader.Read())
            {
                if (xmlTextReader.NodeType == XmlNodeType.Element &&
                    xmlTextReader.LocalName == "item" &&
                    xmlTextReader.IsStartElement() == true)
                {
                    xElem = (XElement)XNode.ReadFrom(xmlTextReader);

                    values[0] = (string)xElem.Element("Index"); // 0
                    values[1] = (string)xElem.Element("Name"); // 1
                    ~~~
                    values[13] = (string)xElem.Element("Notes"); // 13

                    // Thread code addition -- Wait until previous thread finishes
                    if (ThreadStartedS == 1)
                    {
                        t.Join()
                    }

                    // SetValues to record
                    for (int i = 0; i < values.Length; i++)
                    {
                        record.SetValue(i, values[i]); // 0 to 13
                    }

                    // Thread code addition -- Start thread to execute rs.Insert(record)
                    ThreadStartedS = 1;
                    t.Start();

                    // Original code without threads
                    // Insert Record
                    //rs.Insert(record);
                }
            }
        }
    }
}

Answer 1

如果您的所有处理都将在设备上完成(从设备上读取 XML 文件，然后在设备上解析数据)，那么线程化工作不会带来性能提升。

这些 Windows Mobile 设备只有一个处理器，因此对于它们来说，多线程意味着一个进程运行一段时间，然后另一个进程运行一段时间。您永远不会同时运行多个进程。

另一方面，如果 XML 文件中的数据位于远程服务器上，则可以分块调用数据。当一个数据 block 到达时，您可以在另一个线程中处理该数据，同时等待下一个数据 block 到达主线程。

如果所有这些工作都在一台设备上完成，那么多线程就不会有好运气。

您仍然可以显示带有取消按钮的进度条(从 0 到 NumberOfRecords)，这样等待数据收集完成的人就不会因为期待而发疯。