DistributedLockProviderImpl.java

@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@Slf4j
public class DistributedLockProviderImpl implements DistributedLockProvider {

    private final LockProvider lockProvider;

    @Override
    public DistLock lock(String key, int lockAtLeastFor, int lockAtMostFor) {
        var lockConfiguration = new LockConfiguration(Instant.now(), key,
            Duration.ofMillis(lockAtMostFor),
            Duration.ofMillis(lockAtLeastFor)
        );

        return new DistLock(lockProvider.lock(lockConfiguration));
    }

    public class DistLock implements AutoCloseable {

        private Optional<SimpleLock> lock;

        public DistLock(Optional<SimpleLock> lock) {
            this.lock = lock;
        }

        public boolean isPresent() {
            return lock.isPresent();
        }

        public boolean isEmpty() {
            return lock.isEmpty();
        }

        @Override
        public void close() {
            lock.ifPresent(SimpleLock::unlock);
        }

    }
}