diff --git a/scheduler/src/main/java/com/zfoo/scheduler/util/SingleCache.java b/net/src/main/java/com/zfoo/net/util/SingleCache.java similarity index 90% rename from scheduler/src/main/java/com/zfoo/scheduler/util/SingleCache.java rename to net/src/main/java/com/zfoo/net/util/SingleCache.java index e4a738a4..4965c0b6 100644 --- a/scheduler/src/main/java/com/zfoo/scheduler/util/SingleCache.java +++ b/net/src/main/java/com/zfoo/net/util/SingleCache.java @@ -11,10 +11,13 @@ * See the License for the specific language governing permissions and limitations under the License. */ -package com.zfoo.scheduler.util; +package com.zfoo.net.util; import com.zfoo.event.manager.EventBus; +import com.zfoo.scheduler.manager.SchedulerBus; +import com.zfoo.scheduler.util.TimeUtils; +import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; import java.util.function.Supplier; @@ -90,4 +93,8 @@ public class SingleCache { EventBus.asyncExecute(this.hashCode(), () -> cache = supplier.get()); } + public void lazyRefreshDelay(long delay, TimeUnit unit) { + SchedulerBus.schedule(this::lazyRefresh, delay, unit); + } + } diff --git a/scheduler/pom.xml b/scheduler/pom.xml index 6423b38b..3100b1b5 100644 --- a/scheduler/pom.xml +++ b/scheduler/pom.xml @@ -57,12 +57,6 @@ ${zfoo.version} - - com.zfoo - event - ${zfoo.version} - - org.javassist javassist