Как сериализовать лямбда?

Как я могу элегантно сериализовать лямбда?

Например, приведенный ниже код бросает a NotSerializableException. Как я могу исправить это, не создавая интерфейс SerializableRunnable "dummy"?

public static void main(String[] args) throws Exception {
    File file = Files.createTempFile("lambda", "ser").toFile();
    try (ObjectOutput oo = new ObjectOutputStream(new FileOutputStream(file))) {
        Runnable r = () -> System.out.println("Can I be serialized?");
        oo.writeObject(r);
    }

    try (ObjectInput oi = new ObjectInputStream(new FileInputStream(file))) {
        Runnable  r = (Runnable) oi.readObject();
        r.run();
    }
}

Ответы

Ответ 1

Java 8 вводит возможность подвергать объект пересечению типов, добавляя несколько границ. Поэтому в случае сериализации можно написать:

Runnable r = (Runnable & Serializable)() -> System.out.println("Serializable!");

И лямбда автоматически становится сериализуемой.

Ответ 2

Такая же конструкция может использоваться для ссылок на методы. Например, этот код:

import java.io.Serializable;

public class Test {
    static Object bar(String s) {
        return "make serializable";
    }

    void m () {
        SAM s1 = (SAM & Serializable) Test::bar;
        SAM s2 = (SAM & Serializable) t -> "make serializable";
    }

    interface SAM {
        Object action(String s);
    }
}

определяет лямбда-выражение и ссылку на метод с сериализуемым типом цели.

Ответ 3

Очень уродливый актерский состав. Я предпочитаю определять расширение Serializable для функционального интерфейса, который я использую

Например:

interface SerializableFunction<T,R> extends Function<T,R>, Serializable {}
interface SerializableConsumer<T> extends Consumer<T>, Serializable {}

тогда метод, принимающий лямбда, может быть определен как таковой:

private void someFunction(SerializableFunction<String, Object> function) {
   ...
}

и вызывая функцию, вы можете передать свою лямбду без какого-либо уродливого броска:

someFunction(arg -> doXYZ(arg));

Ответ 4

Если вы хотите переключиться на другую структуру сериализации, например Kryo, вы можете избавиться от множества ограничений или требования, реализованный интерфейс должен реализовывать Serializable. Подход к

Измените InnerClassLambdaMetafactory, чтобы всегда генерировать код, необходимый для сериализации
Непосредственно вызовите LambdaMetaFactory во время десериализации

Подробнее и код см. в этом сообщении в блоге

Ответ 5

На случай, если кто-то попадет сюда при создании кода Beam/Dataflow: Beam имеет собственный интерфейс SerializableFunction, поэтому не тратьте время на создание собственного интерфейса или подробное приведение типов.