前言:
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的数据。
网友评论