Untitled

 avatar
unknown
java
3 years ago
699 B
5
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...