Java 中的环形缓冲区

Java中的环形缓冲区

java
public class CircularBuffer {
    private int[] buffer;
    private int readPointer;
    private int writePointer;
    
    public CircularBuffer(int size) {
        buffer = new int[size];
        readPointer = 0;
        writePointer = 0;
    }
    
    public void write(int data) {
        if (isFull()) {
            // 缓冲区已满，无法写入数据
            throw new IllegalStateException("Buffer is full");
        }
        
        buffer[writePointer] = data;
        writePointer = (writePointer + 1) % buffer.length;
    }
    
    public int read() {
        if (isEmpty()) {
            // 缓冲区为空，无法读取数据
            throw new IllegalStateException("Buffer is empty");
        }
        
        int data = buffer[readPointer];
        readPointer = (readPointer + 1) % buffer.length;
        return data;
    }
    
    public boolean isFull() {
        return (writePointer + 1) % buffer.length == readPointer;
    }
    
    public boolean isEmpty() {
        return readPointer == writePointer;
    }
}

java
public class Main {
    public static void main(String[] args) {
        final int BUFFER_SIZE = 10;
        CircularBuffer buffer = new CircularBuffer(BUFFER_SIZE);
        
        // 创建数据输入线程
        Thread producerThread = new Thread(() -> {
            for (int i = 0; i < 100; i++) {
                buffer.write(i);
            }
        });
        
        // 创建数据处理线程
        Thread consumerThread = new Thread(() -> {
            while (true) {
                if (!buffer.isEmpty()) {
                    int data = buffer.read();
                    // 进行数据处理操作
                    System.out.println("Processed data: " + data);
                }
            }
        });
        
        // 启动线程
        producerThread.start();
        consumerThread.start();
    }
}