无缓存高效流(NoCacheStream)

/// <summary>
/// Written in reading
/// </summary>
public class NoCacheStream : Stream
{
    private ManualResetEvent enablewrite = new ManualResetEvent(false);
    private AutoResetEvent enableread = new AutoResetEvent(false);
    private volatile byte[] innerbuffer;
    private int num, inneroffset, innercount;
    private bool isend;

    public override bool CanRead
    {
        get { return true; }
    }

    public override bool CanSeek
    {
        get { return false; }
    }

    public override bool CanWrite
    {
        get { return true; }
    }

    public override void Flush()
    {
        throw new NotImplementedException();
    }

    public override long Length
    {
        get { throw new NotImplementedException(); }
    }

    public override long Position
    {
        get
        {
            throw new NotImplementedException();
        }
        set
        {
            throw new NotImplementedException();
        }
    }

    public override int Read(byte[] buffer, int offset, int count)
    {
        if (isend)
            return 0;

        innerbuffer = buffer;
        inneroffset = offset;
        innercount = count;
        num = 0;
        enablewrite.Set(); // allow write
        enableread.WaitOne(); // wait to read
        return num;
    }

    public override long Seek(long offset, SeekOrigin origin)
    {
        throw new NotImplementedException();
    }

    public override void SetLength(long value)
    {
        throw new NotImplementedException();
    }

    public override void Write(byte[] buffer, int offset, int count)
    {
        if (isend)
            return;

        enablewrite.WaitOne();//wait read method signal

        while (count >= innercount)
        {
            Array.Copy(buffer, offset, innerbuffer, inneroffset, innercount);
            offset += innercount;
            count -= innercount;
            num += innercount;
            enablewrite.Reset();//block write
            enableread.Set();//allow read
            enablewrite.WaitOne();//wait to write
        }

        if (count > 0)
        {
            Array.Copy(buffer, offset, innerbuffer, inneroffset, count);
            inneroffset += count;
            innercount -= count;
            num += count;
        }
    }

    /// <summary>
    /// End of read-write
    /// </summary>
    public void End()
    {
        isend = true;
        enableread.Set();
    }
}