如何在Android/Java中从两个不同的线程中写/读字符串数据

Question

我有一个Android应用程序从线程a中的BLE设备接收ASCII字符串（因此字符串中的每个字符正好对应一个字节）。

这些字符串以最大长度的块形式出现。例如，假设最大长度为4，我们收到以下字符串：

“ABCD”(4)、“EFGH”(4)、“I\R\N”（3）

我很确定我在这里重新发明轮子，但我在网上找不到一个明确的答案。在Java/Android中一定有更好的方法来做到这一点。听起来像是很常见的模式。

我主要是用C#来做事情的，所以我可能会缺少一些类。我还查看了ByteBuffer，但似乎这样做会迫使我实现自己的readLine（）函数，因为没有可供BufferedReader使用的InputStream等。

Answer 1

您可以使用GreenRobot的EventBus轻松地在线程之间发送数据。

GreenRobot的EventBus是一个允许组件（活动、片段、服务和背景线程）之间通信的库。

Build.Gradle

dependencies {      
    compile 'org.greenrobot:eventbus:3.0.0'     
}

public class BleListener{
    private static Context _context;
    private static BleListener _instance;
    private static ListenerThread _listenerThread;
    private static boolean _isListenerThreadEnable = false;

    private BleListener(Context context){
        _context = context;

        // set ble config and open ble port in here
        // ....

        // enable listener thread
        if (!_isListenerThreadEnable) {
             _listenerThread = new ListenerThread();
             _listenerThread.start();
             _isListenerThreadEnable = true;
        }

    }

    // call this function from outer class
    public static BleListener getInstance(Context context) {
        if (_instance == null) {
            _instance = new BleListener(Context context);
        }
        return _instance;
    }

    private class ListenerThread extends Thread {

        ListenerThread() {
            // setting your receive buffer, thread priority in here
        }

        @Override
        public void run() {

            while (_isListenerThreadEnable) {
                synchronized (_bleDevice) {

                    int _receivedCount = _bleDevice.getQueueStatus();

                    while (_receivedCount > 0) {
                        // append your received data in here with ByteBuffer or StringBuffer
                        // ..

                        // parsing data for get valid data
                        // ..

                        // send valid data out when receive special character (end of message flag) or when timeout received with EventBus
                        EventBus.getDefault().post( ValidModal);                    
                    }
                }
                Thread.Yield();
           }
       }
    }
}

@Override
public void onStart() {
    super.onStart();


    EventBus.getDefault().register(this);
}

@Override
public void onStop() {
    EventBus.getDefault().unregister(this);

    super.onStop();
}

@Subscribe(threadMode = ThreadMode.MAIN)
public void onMessage(ValidModal) {
    // You will get valid data from thread A here.
    //..
}