Parallel.ForEach 通过多个线程改变行为

Question

我有一组正在对其执行写操作的文件，我正在使用Parallel.ForEach 循环来加快速度。

问题是，当我有多个线程时，它的行为就会不稳定。该程序向 WAV 文件写入 10 次 250000 个随机字节，这将导致大约 1.3 秒的静态周期。发生的情况是多线程，在绝大多数文件中，没有任何静态，Windows 指示文件已更改，但音频内容没有，另一个问题是某些剪辑有大约 6 分钟的静态写入它，这是不可能的，代码只向每个文件写入 2500000 个字节（约 10.3 秒），因此由于某种原因，它会将字节写入错误的文件，所以有些没有静态，有些则有一个荒谬的数量。它不可能错过静态，所以它不可能是我。我知道出了点问题。

在我多线程程序之前一切正常，所以我使用了MaxDegreeofParallelism = 1，一切正常，所以我知道问题是由多个线程引起的。

Parallel.ForEach(files, new ParallelOptions{MaxDegreeOfParallelism = 4}, file =>
{
Random rand = new Random();
using (stream = new FileStream(file, FileMode.Open, FileAccess.ReadWrite))
{
FileInfo info = new FileInfo(file);
for (int i = 0; i < 10; i++)
{
    int pos = rand.Next(5000000, Convert.ToInt32(info.Length));
    for (int x = 0; x < 250000; x++)
    {
        byte number = array[rand.Next(array.Length)];
        stream.Seek(pos, SeekOrigin.Begin);
        pos += 4;
        stream.WriteByte(number);
    }
}
}
});

编辑：另一个问题是它使用多个线程写入包含关键数据的标题部分，因此没有媒体播放器识别该格式。这只发生在多线程上，我忽略了前 500 万字节，我知道这已经足够了。

编辑：2 更新代码。

谁能解释导致我的代码无法正常运行的多线程是什么？

Answer 1

stream 声明在由Parallel.ForEach 执行的委托之外。 Parallel.ForEach 创建的所有线程都在尝试使用相同的变量。由于没有锁定，因此未定义每个线程将具有的 stream 的值 - 您可能会看到多个线程写入同一个流，这会导致您出现奇怪的多线程行为。

尝试在委托之外删除stream 的声明，然后进行更改

using (stream = new FileStream(file, FileMode.Open, FileAccess.ReadWrite))

到

using (Stream stream = new FileStream(file, FileMode.Open, FileAccess.ReadWrite))

Answer 2

Random number generator 不是线程安全的。 Jon Skeet 对此有一个 good article 以及如何制作线程安全的随机数生成器。