如何序列化一个 lambda？

Question

如何优雅地序列化 lambda？

例如，下面的代码会抛出 NotSerializableException。如何在不创建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

如果你愿意切换到另一个像Kryo这样的序列化框架，你可以摆脱多重界限或者实现的接口必须实现Serializable的要求。方法是

1. 修改InnerClassLambdaMetafactory以始终生成序列化所需的代码
2. 反序列化时直接调用LambdaMetaFactory

详情和代码见blog post

Answer 2

如果有人在创建 Beam/Dataflow 代码时掉到这里：

Beam 有自己的SerializableFunction 接口，因此不需要虚拟接口或冗长的强制转换。

Answer 3

非常丑陋的演员阵容。我更喜欢为我正在使用的功能接口定义一个 Serializable 扩展

例如：

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

那么接受 lambda 的方法可以这样定义：

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

并调用该函数，您可以传递您的 lambda，而无需任何丑陋的演员：

someFunction(arg -> doXYZ(arg));

Answer 4

同样的结构可以用于方法引用。例如这段代码：

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

定义一个 lambda 表达式和一个具有可序列化目标类型的方法引用。

Answer 5

Java 8 引入了cast an object to an intersection of types by adding multiple bounds 的可能性。在序列化的情况下，因此可以这样写：

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

并且 lambda 会自动变为可序列化。