Java线程并发读写

Question

我有一个数组列表，它存储我接收到的数据并通过蓝牙异步传输。

我有一个写入线程和一个读取线程来访问数组列表。我正在尝试模拟蓝牙回声(蓝牙是回声我发送的所有内容)。

private class ReadThread extends Thread {
@Override
public void run() {
    super.run();
        while(!isInterrupted()) {

            try {
                byte[] buffer = new byte[64];
                if (mInputStream == null) return;
                size = mInputStream.read(buffer);
                if (size == 64) {
                    if (bufferList.isEmpty()){
                        Log.i("AOK Fail","Nothing to AOK");
                    }

                    if (compareByte(buffer,bufferList.get(0) == true) // Compare data in this 2 byte array
                          bufferList.remove(0);
                }
            } catch (IOException e) {
            e.printStackTrace();
            return;
        }
    }
}
}

private class WriteThread extends Thread {
    @Override
    public void run() {
    super.run();
    while(!isInterrupted()) {

        try {
            count++;
            if (bufferList.isEmpty() == false && count < 3){    
                write(bufferList.get(0));       
                count = 0;
            }else{
                // Drop data after 3 fail attempt
                bufferList.remove(0);
                count=0;
            }               

            Thread.sleep(500);
        } catch (IOException e) {
            e.printStackTrace();
            return;
        }
    }
}
}

按下按钮后我将发送数据。如果我传输缓慢，效果很好。但是，当我开始快速单击(排队数据进行传输)时，它会失败。一旦我收到 AOK 失败消息。即使新添加数据，所有剩余数据也将全部 AOK Fail。为什么会这样

如果是线程问题，不是应该在所有数据传输后解决吗？

Answer 1

这个bufferList变量是线程安全对象吗？比如数组阻塞列表之类的？如果不是，您在尝试同时添加/删除项目时可能会遇到一些问题。

这会导致生产者线程中出现异常，不会传输任何其他内容，您会收到“Nothing to AOk”日志。