关于如何在这种情况下在 C# 中实现线程的问题

Question

我有这样的场景：Windows 服务在服务器上运行。大约每隔一小时，它就会读取一个日志文件并将内容保存到数据库中。 现在，将有三个文件，必须读取这些文件并将其保存到三个不同的表中。 （我将从配置文件中读取这些连接字符串等）这可以通过我知道的线程来实现。所以我想在线程中调用现有的“readfile”方法。

我不熟悉线程，但这是要走的路吗？

NameValueConfigurationCollection config = ConfigurationManager.GetSection("LogDirectoryPath") as NameValueConfigurationCollection;  

            foreach (DictionaryEntry keyvalue in configs)
            {
               Thread t = new Thread(new ThreadStart(ExecuteProcess(keyvalue.Key.ToString())));
                t.IsBackground = true;
                t.Start();

            }


private void ExecuteProcess(string path)
      {
        var xPathDocument = new XPathDocument(path);
          XPathNavigator xPathNavigator = xPathDocument.CreateNavigator();

        string connectionString = GetXPathQuery(
            xPathNavigator,
            "/connectionString/@value");

        string commandText = GetXPathQuery(
            xPathNavigator,
            "/commandText/@value");

        string filePath = GetXPathQuery(
            xPathNavigator,
            "/filePath/@value");

        SqlConnection sqlConnection = new SqlConnection(connectionString);
        sqlConnection.Open();

        ProcessFiles(sqlConnection, commandText, filePath);
}

我必须使方法静态吗？使用的变量怎么样？

Answer 1

在 .NET 4 中，您可以利用任务并行库来实现此目的，因此您不必显式创建线程，而只需表达您想要并行执行的代码：

Parallel.ForEach(configs.Select( x => x.Key.ToString()), path => ExecuteProcess(path));

Answer 2

我个人偏好是使用 ThreadPool对于我希望在即发即忘场景中并行运行的线程，例如

foreach (DictionaryEntry keyvalue in configs)
{
    ThreadPool.QueueUserWorkItem((state) =>
    {
        ExecuteProcess(keyvalue.Key.ToString());
    });
}

并行任务库也很有用，但不能保证并行，而是处理器的数量。但是，它确实会再次同步所有工作线程。所以这取决于你想要实现什么目标