java实现缓冲区（附完整源码）

以下是一个简单的Java缓冲区实现，附带完整源代码：

public class CustomBuffer {
    private int capacity;
    private char[] buffer;
    private int readIndex;
    private int writeIndex;

    public CustomBuffer(int capacity) {
        this.capacity = capacity;
        this.buffer = new char[capacity];
    }

    public synchronized void write(char c) throws InterruptedException {
        while (writeIndex == capacity) {
            wait();
        }
        buffer[writeIndex++] = c;
        notifyAll();
    }

    public synchronized char read() throws InterruptedException {
        while (readIndex == writeIndex) {
            wait();
        }
        char c = buffer[readIndex++];
        if (readIndex == capacity) {
            readIndex = 0;
            writeIndex = 0;
        }
        notifyAll();
        return c;
    }
}

此代码实现了一个基本的字符缓冲区，其中`capacity`是缓冲区的容量。`buffer`是一个字符数组，用于存储缓冲区中的数据。`readIndex`和`writeIndex`分别表示读取和写入缓冲区的索引。

`write()`方法用于向缓冲区中写入字符，如果缓冲区已满，则线程将等待直到有空间可用。一旦写入完成，它会通知所有等待的线程。

`read()`方法用于从缓冲区中读取字符。如果缓冲区为空，则线程将等待直到有数据可用。一旦读取完成，它会通知所有等待的线程。

在此实现中，我们使用`synchronized`关键字来确保多个线程不会同时访问缓冲区。我们还使用`wait()`和`notifyAll()`方法来控制线程的等待和唤醒。

请注意，此实现仅供参考，并不是最佳实践。如果您需要更高效的缓冲区实现，请考虑使用Java标准库中的`java.nio`包。