0

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

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

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 Fail 消息。所有剩余的数据都将 AOK Fail 即使是新添加的数据。为什么呢

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

4

2 回答 2

1

这段代码的工作原理不是很清楚，因为它不包含一些细节：

  • 你是如何喂养bufferList的，它的类型是什么？也许您在问题中提到的 ArrayList ？ArrayList 不是线程安全的，请参阅Android 的 ArrayList 文档。
  • 用什么write方法？
  • 用什么compareByte方法？这似乎很明显，但最好看看代码，你知道，以防万一（你也错过了一个括号）。
  • count您在 WriteThread 类中使用的var 声明在哪里？您是否count在此代码之外增加价值？如果这是真的，您可能会从bufferList变量 when count >= 3(else block) 中删除所有内容。如果你这样做，你的bufferList.isEmpty() == false && count < 3条件的第一部分有时可能是错误的，因为你的bufferList意志是空的；然后你将执行 else 块，试图从一个空的 ArrayList 中删除一个元素，你的代码将抛出一个 IndexOutOfBoudsException（请参阅ArrayList 删除方法文档）并且你的 WriteThread 将被中止。
于 2013-07-18T14:04:08.513 回答
1

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

这将导致生产者线程中的异常，不会传输任何其他内容，您将获得“Nothing to AOk”日志。

于 2013-07-17T13:11:51.397 回答