如何序列化一个 lambda？

我怎样才能优雅地连载一个 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();
}
}
52427 次浏览
小开
最佳答案

Java8引入了 通过添加多个边界将对象强制转换为类型的交集的可能性。在序列化的情况下，因此可以写:

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

Lambda 会自动变成可序列化的。

小开

方法引用也可以使用相同的结构:

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 表达式和一个具有可序列化目标类型的方法引用。

小开

如果您愿意切换到另一个序列化框架，如 克里奥，您可以摆脱多个界限或实现的接口必须实现 Serializable的要求。方法是

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

有关详细信息和代码，请参阅此 博客文章

小开

非常丑陋的强制类型转换。我更喜欢为我正在使用的函数式接口定义一个可串行化的扩展

例如:

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));
小开

以防有人在创建梁/数据流代码时摔倒在这里:

梁有自己的 序列化函数接口，所以不需要虚拟接口或冗长的转换。


提交答案