LiveData代替LocalBroadcastManager

前言:

LocalBroadcastManager已经被废弃,如何用LiveData代替本地广播(LocalBroadcastManager),实现线程间的通信(抑或不同组件间的通信)。
感谢:如何优雅的使用LiveData实现一套EventBus(事件总线)

项目需求:

多线程并发执行的情况下,每个线程都会执行各自不同的耗时任务。
比方说,A线程进行网络请求,B线程获取手机的位置信息。当A线程网络请求成功后通知B线程重新获取位置信息。那么如何解决线程间的通信?
在LocalBroadcastManager没有被废弃之前,线程间的通信使用的是LocalBroadcastManager。但是LocalBroadcastManager被废弃了。使用LiveData来代替(没有使用过的可以先了解一下LiveData)。

实现:

Step1:包装MutableLiveData(LiveData的子类)。使之成为全局可订阅可发布的对象。

public class LiveDataBus {
    public static MutableLiveData<Object> getInstance(String action) {
        return ready().with(action);
    }

    private final Map<String, MutableLiveData<Object>> bus;

    private LiveDataBus() {
        bus = new HashMap<>();
    }

    private static class InstanceHolder {
        static final LiveDataBus INSTANCE = new LiveDataBus();
    }

    private static LiveDataBus ready() {
        return LiveDataBus.InstanceHolder.INSTANCE;
    }


    private MutableLiveData<Object> with(String key) {
        if (!bus.containsKey(key)) {
            MutableLiveData<Object> liveData = new MutableLiveData<>();
            bus.put(key, liveData);
        }
        return bus.get(key);
    }
}

Step2:订阅MutableLiveData。这里说明一下为什么用到Handler,因为LiveData的observeForever方法必须在主线程中执行,否则报错。所以使用Handler将其抛到主线程执行。

new Handler(Looper.getMainLooper()).post(() ->
        LiveDataBus.getInstance("Event1").observeForever(event -> {
            //接收到通知。
        }));

Step3:发送数据。

 LiveDataBus.getInstance("Event1").postValue("推送数据" + i);

特别说明,LiveData默认所有消息都是粘性事件。所以不管是先订阅还是先发送数据,订阅者都能接收到通知。
另外,postValue会丢失数据,也就是说,如果连续调用postValue的话只会收到最后一次post的数据。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
禁止转载,如需转载请通过简信或评论联系作者。

相关阅读更多精彩内容

友情链接更多精彩内容