Spring的LambdaSafe

阿超

发布于 2024-08-23 19:13:45

550

发布于 2024-08-23 19:13:45

文章被收录于专栏：快乐阿超

对未来来说孩子的教育比成人更为重要。——贝多芬

今天看了下Spring的LambdaSafe类，它提供了一种安全的方式调用Lambda，例如不使用LambdaSafe时的问题

package org.dromara.streamquery.stream.plugin.mybatisplus;

import org.junit.jupiter.api.Test;

import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;

import static org.junit.jupiter.api.Assertions.assertEquals;

/**
 * Tests
 * <p>
 * author achao@apache.org
 */
class TestsWithoutLambdaSafe {

    @Test
    void testWithoutLambdaSafe() {
        List<Consumer<Object>> listeners = new ArrayList<>();
        StringBuilder output = new StringBuilder();

        listeners.add(message -> output.append((String) message).append(" additional"));
        // 导致 ClassCastException
        listeners.add(message -> output.append((Integer) message + 1));

        Object foo = "foo";

        for (Consumer<Object> listener : listeners) {
            try {
                listener.accept(foo);
            } catch (ClassCastException e) {
                output.append(" error: ").append(e.getMessage());
            }
        }

        assertEquals("foo additional error: java.lang.String cannot be cast to java.lang.Integer", output.toString());
    }
}

可以看到这里类型转换异常

但是使用LambdaSafe

package org.dromara.streamquery.stream.plugin.mybatisplus;

import org.junit.jupiter.api.Test;
import org.springframework.boot.util.LambdaSafe;

import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;

import static org.junit.jupiter.api.Assertions.assertEquals;

/**
 * Tests
 * <p>
 * author achao@apache.org
 */
class TestsWithLambdaSafe {

    @Test
    void testWithLambdaSafe() {
        List<Consumer<Object>> listeners = new ArrayList<>();
        StringBuilder output = new StringBuilder();

        listeners.add(message -> output.append((String) message).append(" additional"));
        listeners.add(message -> output.append((Integer) message + 1)); // This will be safely ignored by LambdaSafe

        Object foo = "foo";

        LambdaSafe.callbacks(Consumer.class, listeners, foo)
                .invoke(listener -> listener.accept(foo));

        assertEquals("foo additional", output.toString());
    }
}

可以看到虽然抛了异常，但是在类型不匹配时不影响其他Lambda的结果

不使用 LambdaSafe 的示例：