Circular Buffer 的线程安全

Question

我想确保我的循环缓冲区是线程安全的。我使用缓冲区来存储通过蓝牙传输的数据，同时我使用另一个线程来删除数据并存储在本地 Android 设备中。

这是我当前使用 Semaphore 的 CircularBuffer。是否可以通过简单地将 synchronized 添加到每个方法来使其线程证明？这将是我的首选方法。

public class CircularBuffer {
// private byte[][] data;
private int data[];
private int head;
private int tail;
private Semaphore readPermission;

public CircularBuffer(Integer number) {
    // data = new byte[number][];
    readPermission = new Semaphore(1);
    data = new int[number];
    head = 0;
    tail = 0;
}

public boolean store(byte[] value) {
    if (!bufferFull()) {
        ByteBuffer bb = ByteBuffer.wrap(value);
        // may need to be reversed
        int intVal = bb.getShort();
        Log.i("Buffer Input", "" + intVal);
        // data[tail++] = value;
        data[tail++] = intVal;
        if (tail == data.length) {
            tail = 0;
        }
        return true;
    } else {
        return false;
    }
}

public int getSize() {
    return tail - head;
}

public int read() {
    Log.i("Buffer", "Taking");
    if (head != tail) {
        // byte[] value = data[head++];
        int value=data[head++];
        if (head == data.length) {
            head = 0;
        }
        return value;
    } else {
        //return null;
        return 0;
    }
}

//Getting permission using a semaphore
public void getPermission(){
    try {
        readPermission.acquire();
    } catch (InterruptedException e) {
        Log.i("Buffer", "Interrupted Exception");
        e.printStackTrace();
    }
}

//Giving up permission using a semaphore
public void givePersmission(){
    readPermission.release();
}

}

Answer 1

因为你只需要一个互斥访问synchronized就可以了，但你不需要在所有方法上使用它。只有真正需要同步的方法，
如果您使用信号量，请确保编写异常安全代码，以确保无论发生什么情况都会释放信号量。
从这个角度来看，互斥锁更安全。