Jak serializować lambdę?

Jak mogę elegancko serializować lambdę?

Na przykład poniższy kod generuje plik NotSerializableException. Jak mogę to naprawić bez tworzenia SerializableRunnable„fikcyjnego” interfejsu?

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();
    }
}

Java 8 wprowadza możliwość rzutowania obiektu na przecięcie typów przez dodanie wielu granic . W przypadku serializacji można więc napisać:

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

A lambda automatycznie staje się serializowalna.

Tej samej konstrukcji można użyć do odniesień do metod. Na przykład ten kod:

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);
    }
}

definiuje wyrażenie lambda i odwołanie do metody z możliwym do serializacji typem docelowym.

Bardzo brzydka obsada. Wolę zdefiniować rozszerzenie z możliwością serializacji do interfejsu funkcjonalnego, którego używam

Na przykład:

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

wówczas metodę akceptującą lambdę można zdefiniować następująco:

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

i wywołując funkcję, którą możesz przekazać swoją lambdę bez brzydkiego rzutowania:

someFunction(arg -> doXYZ(arg));

Na wypadek, gdyby ktoś upadł tutaj podczas tworzenia kodu Beam / Dataflow:

Beam ma własny interfejs SerializableFunction, więc nie ma potrzeby stosowania fikcyjnego interfejsu ani pełnych rzutów.

Jeśli chcesz przełączyć się na inną platformę serializacji, taką jak Kryo , możesz pozbyć się wielu ograniczeń lub wymagań, które musi implementować zaimplementowany interfejs Serializable. Podejście to

1. Zmodyfikuj, InnerClassLambdaMetafactoryaby zawsze generował kod wymagany do serializacji
2. Bezpośrednio wywołaj LambdaMetaFactorypodczas deserializacji

Aby uzyskać szczegółowe informacje i kod, zobacz ten wpis na blogu