LiveData代替LocalBroadcastManager

2020-12-16  本文已影响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的数据。

上一篇下一篇

猜你喜欢

热点阅读