美文网首页
LiveData代替LocalBroadcastManager

LiveData代替LocalBroadcastManager

作者: 借风吹箫 | 来源:发表于2020-12-16 14:12 被阅读0次

    前言:

    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的数据。

    相关文章

      网友评论

          本文标题:LiveData代替LocalBroadcastManager

          本文链接:https://www.haomeiwen.com/subject/iabngktx.html