qq_40980991: 方法1改成一个线程，这样可以吗 public Thread initThread() { Thread job = new Thread(() -> {//定义 while (true) { try { Thread.sleep(waitMilliSecond); } catch (InterruptedException e) { e.printStackTrace(); } if (flag) { waitMilliSecond(); }else { flag = true; } } }); return job; } public synchronized void add(T data) { this.dataList.add(data); if (this.dataList.size() == this.maxCount) {//触发 exec("maxCount"); //重置时间与数量 flag = false; timeJob.interrupt(); } }