主页 / 问题 / 821107
Accepted
Иван К
Asked:2020-04-29 22:11:23 +0000 UTC2020-04-29 22:11:23 +0000 UTC

这段代码需要锁吗？

  • 772

如果我要在 Parallel.ForEach 中使用它，你能告诉我这个代码是否需要锁吗？带锁的代码示例：

private IEnumerable<(Byte[] part_bytes, Int32 part_number)> GetPartsFile(FileStream file_stream)
    {
        file_stream.Seek(offset: 0, origin: SeekOrigin.Begin);
        for (Int32 index = 0, part_number = 0; index < file_stream.Length; index += DefaultCopyBufferSize, part_number++)
        {
            lock (this)
            {
                Byte[] bytes = new Byte[DefaultCopyBufferSize];
                Int32 readed_bytes = file_stream.Read(array: bytes, offset: index, count: DefaultCopyBufferSize);
                if (readed_bytes < DefaultCopyBufferSize)
                {
                    Byte[] end_bytes = new Byte[readed_bytes];
                    Buffer.BlockCopy(src: bytes, srcOffset: 0, dst: end_bytes, dstOffset: 0, count: readed_bytes);
                    yield return (end_bytes, part_number);
                }
                else
                {
                    yield return (bytes, part_number);
                }
            }
        }
    }

使用 Parallel.ForEach 的示例：

Parallel.ForEach(
source: GetPartsFile(file_stream: zip_file),
body: tuple =>
{
    //тут ещё какие то действия
});
c#

2 个回答

  1. 关于SynchronizationLockException. 您的方法返回IEnumerable. 当您将此方法指定为 的数据源时Parallel.ForEach()，这意味着序列的不同元素可以由不同的线程请求和处理。

    但这就是它发挥作用的地方yield return。使用这种结构，迭代器的工作方式略有不同：

    1. 该方法开始执行，循环的第一次迭代发生。
    2. 该方法返回序列的第一个元素，而循环的第一次迭代还没有结束。
    3. 当请求下一个元素时，第一次迭代结束，第二次开始，并返回第二个元素。第二次迭代也没有完成。
    4. 就这样围成一圈。

    现在如果我们结合Parallel.ForEach(),yield return和lock，我们会得到以下场景：

    1. 第一个线程请求第一个元素：执行循环的第一次迭代，获取锁，返回第一个元素。锁没有被释放。
    2. 第二个线程请求下一个元素：第一次迭代完成，代码尝试释放锁，我们得到一个异常SynchronizationLockException，表明线程试图调用它不拥有的监视器方法。因为第一个线程进入了监视器，而第二个线程试图退出它。
    • 4
  2. Best Answer

    该方法不需要此代码中的Parallel.ForEach运算符。lock

    参数source- 源 - 在一个线程中执行。但是body- 主体 - 可以在多个线程中执行（或者可能在一个线程中）。

    我注意到阻塞this是危险的。如果其他人锁定了这个类的同一个对象，那么这可能会导致死锁。

    • 3

相关问题