Jak serializować lambda?

Question

Jak mogę elegancko serializować lambda?

Na przykład poniższy kod powoduje wyświetlenie NotSerializableException. Jak mogę to naprawić, nie tworząc interfejsu "fikcyjnego" SerializableRunnable?

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

Answer 1

Java 8 wprowadza możliwość cast an object to an intersection of types by adding multiple bounds. W przypadku serializacji można zatem napisać:

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

A lambda automagicznie staje się serializowalna.

Answer 2

Ta sama konstrukcja może być użyta 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 docelowym typem szeregowania.

Answer 3

Jeśli chcesz przejść do innej architektury serializacji, takiej jak Kryo, możesz pozbyć się wielu ograniczeń lub wymagać, aby zaimplementowany interfejs implementował Serializable. Podejście jest

1. Modyfikacja InnerClassLambdaMetafactory zawsze wygenerować kod wymagany do serializacji
2. Bezpośrednio wywołać LambdaMetaFactory podczas deserializacji

po szczegóły i kod zobaczyć ten blog post

Answer 4

bardzo brzydki obsady . Wolę, aby zdefiniować Serializable rozszerzenie interfejsu funkcjonalnego Używam

Na przykład:

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

wówczas sposób akceptując lambda może być zdefiniowany jako takie:

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

i powołanie funkcja, którą możesz przekazać swojej lambdzie bez brzydkiej obsady:

someFunction(arg -> doXYZ(arg));