API функциональной карты: работа с отдельными записями

В этом примере демонстрируются некоторые ключевые аспекты работы с отдельными записями с использованием API-интерфейса Functional Map:

• Методы с одной записью — это асинхронные возвращающие   экземпляры CompletableFuture, которые предоставляют методы для компоновки и цепочки операций, чтобы можно было чувствовать, что они выполняются последовательно. К сожалению, в Java нет нотации do Haskell или Scala для понимания, чтобы сделать его более приемлемым, но это хорошая новость, что Java наконец-то предлагает механизмы для работы с CompletableFutures неблокирующим способом, даже если они немного более многословны, чем предложено на других языках.
• Все методы обработки данных для WriteOnlyMap возвращают CompletableFuture <Void> , что означает, что пользователь может узнать, когда операция завершена, но ничего другого, потому что функция не может предоставить ничего, что не могло бы быть вычислено заранее или вне функции.
• Тип возврата для большинства методов обработки данных в ReadOnlyMap (и ReadWriteMap ) достаточно гибок. Таким образом, функция может принять решение о возврате информации о значении или метаданных, или для удобства она также может возвратить ReadEntryView, который она получает в качестве параметра. Это может быть полезно для пользователей, желающих вернуть информацию о значении и параметрах метаданных.
• Операция чтения-записи, показанная выше, показала, как удалить запись и вернуть ранее связанное значение. В этом конкретном случае мы знаем, что есть значение, связанное с записью, и, следовательно, мы вызвали ReadEntryView.get () напрямую, но если мы не были уверены, присутствует ли это значение или нет,  следует вызвать ReadEntryView.find () и вернуть Необязательный экземпляр вместо.
• В этом примере параметр метаданных Lifespan создается с использованием нового API времени Java, доступного в Java 8, но его можно было бы сделать в равной степени с  java.util.concurrent.TimeUnit, если преобразование выполнялось в число миллисекунд, в течение которых запись должен быть доступен.
• Срок действия, основанный на сроке службы, работает так же, как и с другими API Infinispan, поэтому вы можете легко изменить пример, чтобы уменьшить срок службы, подождать, пока пройдет продолжительность, а затем убедиться, что значение больше не присутствует.

Если хранится постоянное значение, WriteOnlyMap.eval (K, Consumer) может использоваться вместо  WriteOnlyMap.eval (K, V, Consumer) , что делает код более понятным, но если значение является переменным,  WriteOnlyMap.eval (K, V, Потребитель) следует использовать, чтобы избежать, насколько это возможно, функций, собирающих внешние переменные. Ясно, что операции, предоставляемые функциональной картой, не могут охватывать все сценарии, и могут быть ситуации, когда внешние переменные захватываются функциями, но в целом их должно быть меньшинство. Вот пример, показывающий, как реализовать ConcurrentMap.replace (K, V, V), где требуется захват внешних переменных:

import org.infinispan.commons.api.functional.FunctionalMap.ReadWriteMap;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;

ReadWriteMap<String, String> readWriteMap = ...

// First, do a put-if-absent like operation
CompletableFuture<Boolean> putIfAbsentFuture = readWriteMap.eval("key1", readWriteView -> {
   Optional<String> opt = readWriteView.find();
   boolean isAbsent = !opt.isPresent();
   if (isAbsent) readWriteView.set("value1");
   return isAbsent;
});

// Chain the put if absent with an operation to log whether the put-if-absent was successful
CompletableFuture<Void> logPutIfAbsentFuture = putIfAbsentFuture.thenAccept(
   success -> System.out.printf("Put if absent successful? %s%n", success));

// Next, chain a replace operation comparing a captured value via equals
String oldValue = "value1";
CompletableFuture<Boolean> replaceFuture = logPutIfAbsentFuture.thenCompose(x ->
   readWriteMap.eval("key1", "value2", (v, readWriteView) ->
      readWriteView.find().map(prev -> {
         if (prev.equals(oldValue)) {
            readWriteView.set(v);
            return true; // Old value matches so set new value and return success
         }
         return false; // Old value does not match
      }).orElse(false) // No value found in the map
));

// Finally, log the result of replace
CompletableFuture<Void> logReplaceFuture = replaceFuture.thenAccept(
   replaced -> System.out.printf("Replace successful? %s%n", replaced));

// Wait for the chain of operations to complete
logReplaceFuture.get();