原来 Lamda 表达式是这样写的
低并发编程
共 1051字,需浏览 3分钟
·
2021-10-16 03:54
低并发的友友们好,我是闪客。
List studentList = gen();
Map map = studentList .stream()
.collect(Collectors.toMap(Student::getId, a -> a, (a, b) -> a));
1. 确认 Lamda 表达式的类型
2. 找到要实现的方法
3. 实现这个方法
确认 Lamda 表达式的类型
@FunctionalInterface
public interface Runnable {
public abstract void run();
}这就是一个标准的函数式接口。 因为只有一个抽象方法。而且这个接口上有个注解
// 没有实现任何抽象方法的接口
@FunctionalInterface
public interface MyRunnable {}
// 编译后控制台显示如下信息
Error:(3, 1) java:
意外的 @FunctionalInterface 注释
MyRunnable 不是函数接口
在 接口 MyRunnable 中找不到抽象方法
@FunctionalInterface
public interface Consumer<T> {
void accept(T t);
default Consumer andThen(Consumer super T> after) {...}
}
@FunctionalInterface
public interface Predicate<T> {
boolean test(T t);
default Predicate and(Predicate super T> other) {...}
default Predicate negate() {...}
default Predicate or(Predicate super T> other) {...}
static Predicate isEqual(Object targetRef) {...}
static Predicate not(Predicate super T> target) {...}
}
找到要实现的方法
@FunctionalInterface
public interface Runnable {
public abstract void run();
}
@FunctionalInterface
public interface Consumer<T> {
void accept(T t);
default Consumer andThen(Consumer super T> after) {...}
}
@FunctionalInterface
public interface Predicate<T> {
boolean test(T t);
default Predicate and(Predicate super T> other) {...}
default Predicate negate() {...}
default Predicate or(Predicate super T> other) {...}
static Predicate isEqual(Object targetRef) {...}
static Predicate not(Predicate super T> target) {...}
}
实现这个方法
Predicate predicate = new Predicate() {
@Override
public boolean test(String s) {
return s.length() != 0;
}
};
Predicate
predicate =
(String s) -> {
return s.length() != 0;
};看出来了么?这个 Lamda 语法由三部分组成:
参数块:就是前面的 (String s),就是简单地把要实现的抽象方法的参数原封不动写在这。
小箭头:就是 -> 这个符号。
代码块:就是要实现的方法原封不动写在这。
Predicate predicate =
(s) -> {
return s.length() != 0;
};
Predicate
predicate =
s -> {
return s.length() != 0;
};
Predicate
p = s -> s.length() != 0;
@FunctionalInterface
public interface Runnable {
public abstract void run();
}
Runnable r = () -> System.out.println("I am running");
new Thread(() -> System.out.println("I am running")).start();
多个入参
@FunctionalInterface
public interface BiConsumer<T, U> {
void accept(T t, U u);
// default methods removed
}
BiConsumer randomNumberPrinter =
(random, number) -> {
for (int i = 0; i < number; i++) {
System.out.println("next random = " + random.nextInt());
}
};
randomNumberPrinter.accept(new Random(314L), 5));
@FunctionalInterface
public interface BiFunction<T, U, R> {
R apply(T t, U u);
// default methods removed
}
// 看个例子
BiFunction findWordInSentence =
(word, sentence) -> sentence.indexOf(word);
发现规律了没
@FunctionalInterface
public interface DoubleFunction<R> {
R apply(double value);
}
@FunctionalInterface
public interface Function<T, R> {
R apply(T t);
}
用我们常见的 Stream 编程熟悉一下
List studentList = gen();
Map map = studentList .stream()
.collect(Collectors.toMap(Student::getId, a -> a, (a, b) -> a));
Collectors.toMap(Student::getId, a -> a, (a, b) -> a)
Collectors.toMap(a -> a.getId(), a -> a, (a, b) -> a)
public static
Collector > toMap(
Function super T, ? extends K> keyMapper,
Function super T, ? extends U> valueMapper,
BinaryOperator mergeFunction)
{
return toMap(keyMapper, valueMapper, mergeFunction, HashMap::new);
}
Collectors.toMap(a -> a.getId(), Function.identity(), (a, b) -> a)
@FunctionalInterface
public interface Function<T, R> {
R apply(T t);
...
staticFunction identity() {
return t -> t;
}
}
@FunctionalInterface
public interface Predicate<T> {
boolean test(T t);
default Predicateand(Predicate super T> other) {
Objects.requireNonNull(other);
return (t) -> test(t) && other.test(t);
}
}
Predicate
p =
s -> (s != null) &&
!s.isEmpty() &&
s.length() < 5;
Predicate nonNull = s -> s != null;
Predicate nonEmpty = s -> s.isEmpty();
Predicate shorterThan5 = s -> s.length() < 5;
Predicate p = nonNull.and(nonEmpty).and(shorterThan5);
方法引用
Function
toLength = s -> s.length();
FunctiontoLength = String::length;
FunctiongetName = user -> user.getName();
FunctiontoLength = User::getName;
Consumerprinter = s -> System.out.println(s);
Consumerprinter = System.out::println;
Supplier
> newListOfStrings = () -> new ArrayList<>();
Supplier> newListOfStrings = ArrayList::new;
总结
1. 确认 Lamda 表达式的类型
2. 找到要实现的方法
3. 实现这个方法
评论