在開發(fā)有時候會通過很多方式處理事件防抖效果仰美，比如計時器，時間差儿礼，今天采用自定義RxJava操作符和時間差分別進行處理咖杂。
傳統處理方式：
public abstract class OnMultiClickListener implements View.OnClickListener {
public static final int MIN_CLICK_DELAY_TIME = 1000;
private long lastClickTime = 0;
@Override
public void onClick(View v) {
long currentTime = Calendar.getInstance().getTimeInMillis();
if (currentTime - lastClickTime > MIN_CLICK_DELAY_TIME) {
lastClickTime = currentTime;
onMultiClick(v);
}
}
public abstract void onMultiClick(View v);
}
獲取系統時間，第一次可以點擊蚊夫，后續(xù)要加上時間間隔判斷诉字，大于設定的時間間隔再執(zhí)行點擊，很簡潔知纷。
先看RxJava中的操作符是怎么實現壤圃，就以create操作符為例，其實create就是RxJava中的方法琅轧，先瞅瞅：
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public static <T> Observable<T> create(ObservableOnSubscribe<T> source) {
ObjectHelper.requireNonNull(source, "source is null");
return RxJavaPlugins.onAssembly(new ObservableCreate<T>(source));
}
在create()方法中傳入了ObservableOnSubscribe對象 自定義資源對象伍绳，而ObservableCreate對象持有sourced對象的引用，繼續(xù)往下看：
ObservableOnSubscribe
@Override
protected void subscribeActual(Observer<? super T> observer) {
CreateEmitter<T> parent = new CreateEmitter<T>(observer);
observer.onSubscribe(parent);
try {
source.subscribe(parent);
} catch (Throwable ex) {
Exceptions.throwIfFatal(ex);
parent.onError(ex);
}
}
代碼中出現CreateEmitter對象持有Observer對象鹰晨，并調用observer.onSubscribe(parent);最后我們在揭開CreateEmitter真明目:
static final class CreateEmitter<T>
extends AtomicReference<Disposable>
implements ObservableEmitter<T>, Disposable {
final Observer<? super T> observer;
@Override
public void onNext(T t) {
if (t == null) {
onError(new NullPointerException("onNext called with null. Null values are generally not allowed in 2.x operators and sources."));
return;
}
if (!isDisposed()) {
observer.onNext(t);
}
}
@Override
public void onError(Throwable t) {
if (!tryOnError(t)) {
RxJavaPlugins.onError(t);
}
}
@Override
public void onComplete() {
if (!isDisposed()) {
try {
observer.onComplete();
} finally {
dispose();
}
}
}
public void dispose() {
DisposableHelper.dispose(this);
}
@Override
public boolean isDisposed() {
return DisposableHelper.isDisposed(get());
}
}
上述代碼片段中CreateEmitter對象中提供了5個方法墨叛，onNext(), onError(),onComplete(),dispose(),isDisposed(),分別是拿到最終的結果值止毕，在事件的執(zhí)行過成功出現異常，提交完畢漠趁，事件中斷扁凛，事件是否中斷等一些列方法，上述是create操作符的一個大致流程闯传，在事件的傳遞過程中谨朝，上游發(fā)出的事件進行層層封裝，那么同時Observer在上游包裝的同時也會層層封裝甥绿，兩者一一對應字币，如圖所示：
image.png
RxJava處理方式：
剛剛對create操作符流程進行分析，現在開始自定義的操作：clicks操作符
RxView
companion object{
fun clicks(view: View): ViewClickObservable {
return ViewClickObservable(view)
}
}
RxView類中就只有一個靜態(tài)方法共缕，click()與create()類似洗出。
ViewClickObservable
override fun subscribeActual(observer: Observer<in Any?>) {
val myListener = MyListener(mView!!, observer)
observer!!.onSubscribe(myListener)
mView!!.setOnClickListener(myListener)
}
ViewClickObservable繼承Observable，復寫subscribeActual(),將傳遞observer對象進行封裝图谷，最后附上MyListener類片段：
override fun dispose() {
// 如果沒有中斷過翩活，才有資格， cas機制
if(isDisposable.compareAndSet(false,true)){
//判斷是否是主線程
if (Looper.getMainLooper()== Looper.myLooper()){
mView!!.setOnClickListener(null)
}else{
//則需要從子線程切換到主線程
//1便贵、通過創(chuàng)建handler的方式進行切換線程
/*object : Handler(Looper.getMainLooper()) {
override fun handleMessage(msg: Message) {
super.handleMessage(msg)
mView!!.setOnClickListener(null)
}
}
*/
//2菠镇、通過RxJava的源碼分析 AndroidSchedulers.mainThread() 也是從子線程中去切換回到主線程
AndroidSchedulers.mainThread().scheduleDirect(object:Runnable{
override fun run() {
mView!!.setOnClickListener(null)
}
})
}
}
}
dispose()法特別強調一點，中斷事件承璃，其實就是讓View沒有點擊事件利耍，那么我在這兒將view的點擊事件設置為null， mView!!.setOnClickListener(null)盔粹，但是得注意一點隘梨，要在主線程中對view進行操作，于是乎就有了代碼中的兩種切換線程的方式玻佩，第一種：就是我們平時在碼代碼中的new Handler對象出嘹，在handler中進行View的事件設置，Handler(Looper.getMainLooper()) ?? 那在Handler中傳入Looper.getMainLooper()干啥呢咬崔？這個其實就是為了確保一定是在主線程中税稼，那又有很多同學會問handler不就是用于子線程和主線程之間進行通訊的嘛，沒錯垮斯，但是handler 不僅可以用于主線程和子線程之間的通訊郎仆，也可以用于子線程與子線程之間的通訊，比如：
private Handler childHandler;
private void test(){
new Thread(new Runnable() {
@Override
public void run() {
String msg;
Looper.prepare();
childHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
System.out.println("這個消息是從-->>" + msg.obj+ "過來的兜蠕，在" + "btn的子線程當中" + "中執(zhí)行的");
}
};
Looper.loop();//開始輪循
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
Looper loop = Looper.myLooper();
Message msg = childHandler.obtainMessage();
msg.obj = "btn2當中子線程";
childHandler.sendMessage(msg);
}
}).start();
}
開發(fā)中很多小伙伴都不會才用這種方式進行寫代碼扰肌，只是想確保Handler一定是在主線程中，第二種方式熊杨，在RxJava中很多時候都是采用第二種方式進行線程的切換曙旭。最后我們測試一下：
//自定義RxJava操作符
RxView.clicks(imageView!!)
.throttleFirst(2000, TimeUnit.MILLISECONDS) // 2秒鐘之內 響應你一次
.flatMap { Observable.just("張三") }
.observeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()) // 給下面切換 主線程
.subscribe(Consumer<Any> { name ->
Log.d("TAG", "name=: $name")
})
通過點擊ImageView2s中之內發(fā)送一次姓名為張三的事件：
結果.png
