c#从流中读取特定类型数组的有效方法

Question

我正在寻找一种从流中读取特定类型的多个数组的有效方法。

到目前为止，我正在使用下面这样的类来读取单个值，例如：int, byte, sbyte, uint, short, ushort, ... 但也适用于数组，例如：ushort[]、short[]、uint[]、int[]、byte[]、sbyte[]、...

    public byte[] ReadBytes(int count)
    {
      byte[] buffer = new byte[count];
      int retValue = _Stream.Read(buffer, 0, count);
      return buffer;
    }

    public ushort ReadUshort()
    {
      byte[] b = ReadBytes(2);
      if (BitConverter.IsLittleEndian) // for motorola (big endian)
        Array.Reverse(b);
      return BitConverter.ToUInt16(b, 0);
    }

    public ushort[] ReadUshorts(int count) 
    {
       ushort[] data = new ushorts[count];
       for (int i = 0; i < count; i++)
       {
          data[i] = ReadUshort();
       }
       return data;
    }

   public uint ReadUint() 
   {
       byte[] b = ReadBytes(4);
      if (BitConverter.IsLittleEndian) // for motorola (big endian)
        Array.Reverse(b);
      return BitConverter.ToUInt32(b, 0);
   }

   public uint[] ReadUints(int count)
   {
      // ...
   }

与我在这里共享的代码 sn-p 相比，有没有更有效的方法来读取数组？

我有一种感觉，for-loop 和每次读取调用的组合并不是那么有效。但问题是我每次都需要检查 IsLittleEndian 并在需要时反转，所以我可以读取多个字节。不确定这是否可以更有效地重写。

Answer 1

您可以编写一个泛型方法，并使用Buffer.BlockCopy 将数据复制到目标数组中：

    public static T[] ReadElements<T>(Stream input, int count)
    {
        int bytesPerElement = Marshal.SizeOf(typeof(T));
        byte[] buffer = new byte[bytesPerElement * count];

        int remaining = buffer.Length;
        int offset = 0;
        while (remaining > 0)
        {
            int read = input.Read(buffer, offset, remaining);
            if (read == 0) throw new EndOfStreamException();
            offset += read;
            remaining -= read;
        }

        if (BitConverter.IsLittleEndian)
        {
            for (int i = 0; i < buffer.Length; i += bytesPerElement)
            {
                Array.Reverse(buffer, i, bytesPerElement);
            }
        }

        T[] result = new T[count];
        Buffer.BlockCopy(buffer, 0, result, 0, buffer.Length);
        return result;
    }