JAVA Reader源码分析

针对字符数据的读取， Java SE 提供了 java.io.Reader 类，其抽象化了字符数据读入的来源。

Reader的子类只需重写read(char[], int, int) 和 close()方法，但是一般子类为了提高效率会将其他非抽象的方法重写。

public abstract class Reader implements Readable, Closeable {

    /**
     用来在流上同步操作的对象。为了提高效率，字符流对象可以使用其自身以外的对象来保护关键部分。
     因此，子类应使用此字段中的对象，而不是 this 或者同步的方法。
     */
    protected Object lock;

    /**
     其重要部分将同步其自身的reader
     */
    protected Reader() {
        this.lock = this;
    }

    /**
     *暂时有点不懂
     * Creates a new character-stream reader whose critical sections will
     * synchronize on the given object.
     */
    protected Reader(Object lock) {
        if (lock == null) {
            throw new NullPointerException();
        }
        this.lock = lock;
    }

    /**
     *试图将字符读入指定的字符缓冲区。缓冲区可照原样用作字符的存储库：所做的唯一改变是 put操作的结果。
     *不对缓冲区执行翻转或重绕操作。
     */
    public int read(java.nio.CharBuffer target) throws IOException {
        int len = target.remaining();
        char[] cbuf = new char[len];
        int n = read(cbuf, 0, len);
        if (n > 0)
            target.put(cbuf, 0, n);
        return n;
    }

    /**
     * 读取一个字符，这里的重载Read方法都基于read(char[], int, int)
     */
    public int read() throws IOException {
        char cb[] = new char[1];
        if (read(cb, 0, 1) == -1)
            return -1;
        else
            return cb[0];
    }

    public int read(char cbuf[]) throws IOException {
        return read(cbuf, 0, cbuf.length);
    }


    abstract public int read(char cbuf[], int off, int len) throws IOException;

    /*当执行skip时，表示能跳过的最大的字节个数*/
    private static final int maxSkipBufferSize = 8192;

    private char skipBuffer[] = null;

    /*skip方法使用了一个byte型的数组当做缓冲区，
     *重复地读取数据，直到读取了n个字节或者已经到了数据流的尾部。
     *鼓励用子类来重写这个方法以获得更高的效率。*/

    public long skip(long n) throws IOException {
        if (n < 0L)
            throw new IllegalArgumentException("skip value is negative");
        int nn = (int) Math.min(n, maxSkipBufferSize);
        synchronized (lock) {
            if ((skipBuffer == null) || (skipBuffer.length < nn))
                skipBuffer = new char[nn];
            long r = n;
            while (r > 0) {
                int nc = read(skipBuffer, 0, (int)Math.min(r, nn));
                if (nc == -1)
                    break;
                r -= nc;
            }
            return n - r;
        }
    }

    /**
     * 判断该字符流是否已经准备好读取。
     */
    public boolean ready() throws IOException {
        return false;
    }

    public boolean markSupported() {
        return false;
    }


    public void mark(int readAheadLimit) throws IOException {
        throw new IOException("mark() not supported");
    }


    public void reset() throws IOException {
        throw new IOException("reset() not supported");
    }

    abstract public void close() throws IOException;
}