Измерение производительности сериализации Lambdas с JMH

Долгожданным дополнением к Java 8 стала Lambdas. Они имеют ряд применений, таких как:

Сокращение стандартного кода, который вам необходим для анонимных внутренних классов.

Сокращение объема захваченных значений. Лямбды неявно включают в себя this внешнего класса, уменьшая утечки памяти.

Простая интеграция с существующими API и новым API Streams.

Менее известной особенностью лямбд является то, что они могут быть сериализованы.

Зачем сериализовать лямбду?

Сериализация полезна для сохранения состояния и передачи объектов по сети. Лямбды должны быть как можно без сохранения состояния, поэтому, хотя вы можете сохранять лямбды, это не очевидный вариант использования. 

Лямбды предназначены для передачи фрагментов кода в библиотеку, чтобы обеспечить взаимодействие с тем, что делает библиотека. Но что, если библиотека поддерживает распределенную систему, такую ​​как Chronicle Engine?

Что такое хроника двигателя?

Chronicle Engine — это библиотека, которая позволяет вам получать удаленный доступ к структурам данных в вашем приложении как клиенту Java или C #, так и файловой системе NFS. Он также поддерживает хранение и сохранение данных из кучи, а также репликацию.

Лямбды в распределенных системах

Лямбда может быть простым способом выполнения операции, которая может выполняться или не выполняться локально. Вы можете выполнять такие операции, как:

MapView<String, Long> map = acquireMap(“map-name”, 
                                      String.class, Long.class);
map.put(“key”, 1);
long ret = map.applyToKey(“key”, v -> v + 1); // ret == 2

Function<String, String> appendStar = s -> s + "*"

String star = "*";
Function<String, String> appendStar = s -> s + star;

Function<String, String> appendStar = 
     (Function<String, String> & Serializable) (s -> s + star);

@FunctionalInterface
public interface SerializableFunction<I, O> 
       extends Function<I, O>, Serializable {

SerializableFunction<String, String> appendStar = s -> s + star;

<R> R applyToKey(K key, @NotNull SerializableFunction<E, R> function) {

String s = map.applyToKey(“key”, s-> s + “*”);

// print the last name of all the people in NYC
acquireMap(“people”, String.class, Person.class).query()
  .filter(p -> p.getCity().equals(“NYC”)) // executed on the server
  .map(p → p.getLastName())  // executed on the server
  .subscribe(System.out::println); // executed on the client.

enum Functions implements SerializableFunction<String, String> {
    APPEND_STAR {
        @Override
        public String apply(String s) {
            return s + '*';
        }
    }
}

!SerializedLambda {
  cc: !type lambda.LambdaSerialization,
  fic: net/openhft/chronicle/core/util/SerializableFunction,
  fimn: apply,
  fims: (Ljava/lang/Object;)Ljava/lang/Object;,
  imk: 6,
  ic: lambda/LambdaSerialization,
  imn: lambda$textWireSerialization$ea1ad110$1,
  ims: (Ljava/lang/String;)Ljava/lang/String;,
  imt: (Ljava/lang/String;)Ljava/lang/String;,
  ca: [
  ]
}

!Functions APPEND_STAR