1

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

这是我目前CircularBuffer使用Semaphore的 . 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();
}

}
4

1 回答 1

0

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

于 2012-02-14T20:40:52.683 回答