本文主要向大家介绍了JAVA语言 操作防抖（非Rxjava方案），通过具体的内容向大家展示，希望对大家学习JAVA语言有所帮助。

JAVA 操作防抖，在手机网络状态变化时发生了重复调用，因此需要进行防抖。
本打算用RxJava方案的，发现没必要那么麻烦，就找了个现成的类修改了下，发现确实还比较好用，代码如下。
package com.xxx.xxx; import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.Executors;import java.util.concurrent.ScheduledExecutorService;import java.util.concurrent.TimeUnit; /** * 操作防抖 * @param  参数类型 */public class Debouncer { private final ScheduledExecutorService sched = Executors.newScheduledThreadPool(1); private final ConcurrentHashMap delayedMap = new ConcurrentHashMap(); private final Callback callback; private final int interval;  public interface Callback {  void call(T param); }  public Debouncer(Callback c, int interval) {  this.callback = c;  this.interval = interval; }  public void call(T param) {  TimerTask task = new TimerTask(param);   TimerTask prev;  do {prev = delayedMap.putIfAbsent(param, task);if (prev == null) sched.schedule(task, interval, TimeUnit.MILLISECONDS);  }  while (prev != null && !prev.extend()); // Exit only if new task was added to map, or existing task was extended successfully }  public void terminate() {  sched.shutdownNow(); }  // The task that wakes up when the wait time elapses private class TimerTask implements Runnable {  private final T param;  private long dueTime;  private final Object lock = new Object();   public TimerTask(T param) {this.param = param;extend();  }   public boolean extend() {synchronized (lock) { if (dueTime < 0) // Task has been shutdown  return false; dueTime = System.currentTimeMillis() + interval; return true;}  }   public void run() {synchronized (lock) { long remaining = dueTime - System.currentTimeMillis(); if (remaining > 0) { // Re-schedule task  sched.schedule(this, remaining, TimeUnit.MILLISECONDS); } else { // Mark as terminated and invoke callback  dueTime = -1;  try {callback.call(param);  } finally {delayedMap.remove(param);  } }}  } }}
调用：
private Debouncer debouncer = new Debouncer(new Debouncer.Callback(){  @Override  public void call(String param) {System.out.println("call with param:" + param);  } }, 500); debouncer.call("参数A");   

本文由职坐标整理并发布，希望对同学们有所帮助。了解更多详情请关注编程语言JAVA频道！