如何使用 foreach 循环制作多线程应用程序

本文关键字：多线程应用程序循环何使用 foreach | 更新日期: 2023-09-27 18:16:55

有一个应用程序，可以按某些条件对大型txt文件进行排序。我需要启动例如 5 个线程，但我使用 foreach 循环从文件中逐行读取。如果我用我的代码启动 5 个线程，所有线程都将采用相同的行。

这是我启动 1 个线程的代码：

    Thread[] thr;
    private void button1_Click(object sender, EventArgs e)
    {
        button1.Enabled = false;
        button4.Enabled = true;
        decimal value = 1;
        int i = 0;
        int j = (int)(value);
        thr = new Thread[j];
        for (; i < j; i++)
        {
            thr[i] = new Thread(new ThreadStart(go));
            thr[i].IsBackground = true;
            thr[i].Start();
        }
    }
    private static IEnumerable<string> ReadLineFromFile(TextReader fileReader)
    {
        using (fileReader)
        {
            string currentLine;
            while ((currentLine = fileReader.ReadLine()) != null)
            {
                yield return currentLine;
            }
        }
    }

    public void go()
    {
        while (true)
        {
            TextReader readFile = new StreamReader(file_path, System.Text.Encoding.UTF8, true);
            foreach (string line in ReadLineFromFile(readFile))
            {
                if (line.Split(':')[0].Contains("@"))
                {
                    string out_line = line.Split(':')[0].Replace("+", "") + ":" + line.Split(':')[1];
                    lock (locker)
                    {
                        mail_count++;
                        log_mail(mail_count);
                        mail.Add(out_line.Trim().Replace(";", ":"));
                    }
                }
                else
                {
                    string out_line = line.Split(':')[0].Replace("+", "") + ":" + line.Split(':')[1];
                    lock (locker)
                    {
                        rubbish_count++;
                        log_rubbish(rubbish_count);
                        rubbish.Add(out_line.Trim());
                    }
                }
            }
            MessageBox.Show("Ready");
            BeginInvoke(
            new MethodInvoker(() =>
            {
                button1.Enabled = true;
                button4.Enabled = false;
            }));
            break;
        }
    }

所有线程读取同一个文件是没有用的，从共享文件中读取是困难且低效的。

在你的主函数中，你需要这样的东西：

Parallel.ForEach(System.IO.File.ReadLines(file_path, System.Text.Encoding.UTF8), 
   line => ProcessOneLine(line) 
);

然后ProcessOneLine将执行.Split(':')等操作。

为什么不采用通常的生产者-消费者模式呢？创建一个线程读取文件，将行放入某个共享集合中，其他线程只是从集合中选取数据并对其进行处理。

更多 - 您可以从文件中读取并为每一行创建Task，该将负责处理此行并将结果放入输出集合中。

这似乎比 5 个线程尝试读取同一文件而不多次读取同一行要好。

我想确认并扩展Pako所说的话。其他线程应使用包含数据的共享集合中的数据并对其进行处理。

让多个线程访问一个文本文件听起来像是可能发生争用条件。如果一个线程正在更改文件，而另一个线程正在从中读取文件，则可能会出现本质上不可预测的结果。

我过去也遇到过蓝屏，当使用多个线程访问同一个文本文件并可以推荐它时。但是，如果您坚持这样做，我建议您查看"lock"关键字和单例设计模式。这将允许您确保一次只有一个线程访问该文件。