将记录插入移动到 SQL Server CE 数据库到另一个线程中?C# 紧凑框架 3.5

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

我在下面有以下代码（带有带有注释的线程添加），其中我解析大型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);之前，我传递给线程的记录不会更改。因此，我试图放置线程。Join（） 在写入新记录 （ record.SetValue(i, values[i]); ） 之前，但是当我尝试运行程序时我仍然会遇到冲突 - 由于尝试多次写入相同的行（尤其是对于索引），程序崩溃并出现一堆错误。

谁能帮我一些建议？如何将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);
                }
            }
        }
    }
}