3

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

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

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

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

和

rs.Insert(record);

花费大约相同的时间来执行。我正在考虑rs.Insert(record);在解析下一行 xml 文件时运行。但是，我仍然无法使用 Thread 或 ThreadPool 来做到这一点。

我必须确保rs.Insert(record);在现有线程中完成执行之前，我传递给线程的记录不会改变。因此，我尝试在写入新记录 () 之前放置 thread.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);
                }
            }
        }
    }
}
4

1 回答 1

1

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

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

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

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

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

于 2013-09-10T18:46:35.393 回答