Untitled
Anonymous
java
12/23/2022 10:55 AM
932 B
23
Indexable
public LockableTaskScheduler getLockableTaskScheduler() {
final LockConfigurationExtractor lockConfigurationExtractor = task -> Optional.of(
new LockConfiguration(
Instant.now(),
"taskName",
Duration.ofSeconds(5),
Duration.ofSeconds(5)));
final var lockManager = new DefaultLockManager(lockProvider,
lockConfigurationExtractor);
final var threadPoolTaskScheduler = (ThreadPoolTaskScheduler) taskScheduler;
threadPoolTaskScheduler.shutdown();
threadPoolTaskScheduler.initialize();
return new LockableTaskScheduler(threadPoolTaskScheduler, lockManager);
}Editor is loading...