Làm thế nào để tuần tự hóa một lambda?

Question

Làm thế nào tôi có thể sắp xếp một cách thanh lịch một lambda?

Ví dụ: mã bên dưới ném một số NotSerializableException. Làm cách nào để khắc phục sự cố mà không cần tạo giao diện "giả" 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 giới thiệu khả năng cast an object to an intersection of types by adding multiple bounds. Trong trường hợp serialization, do đó có thể viết:

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

Và lambda automagically trở thành serializable.

Answer 2

Có thể sử dụng cùng một cấu trúc cho tham chiếu phương pháp. Ví dụ: mã này:

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

xác định biểu thức lambda và tham chiếu phương pháp với loại mục tiêu có thể tuần tự.

Answer 3

Nếu bạn sẵn sàng chuyển sang một khung công tác tuần tự hóa khác như Kryo, bạn có thể loại bỏ nhiều giới hạn hoặc yêu cầu giao diện được triển khai phải thực hiện Serializable. Cách tiếp cận này để

1. Sửa đổi InnerClassLambdaMetafactory để luôn tạo mã cần thiết cho serialization
2. Gọi trực tiếp đến các LambdaMetaFactory trong deserialization

Để biết chi tiết và mã thấy blog post

Answer 4

cast Rất xấu xí này . Tôi thích để xác định một phần mở rộng Serializable đến giao diện chức năng Tôi đang sử dụng

Ví dụ:

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

sau đó phương pháp chấp nhận lambda có thể được định nghĩa như vậy:

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

và gọi chức năng bạn có thể vượt qua lambda của bạn mà không có bất kỳ diễn viên xấu xí:

someFunction(arg -> doXYZ(arg));