ATL CEO 领导力沟通稿

Size: px

Start display at page:

Download "ATL CEO 领导力沟通稿"

坡柳
7 years ago
Views:

1 Java 8 函数式编程 Functional Programming 于文琦

2 Lambda λ 希腊字母表中第十一位物理上的波长符号线性代数中的特征值

3 About Functional Programming 什么是函数式编程? 是一种编程范式, 是如何编程的方法论 (Methodology) 什么是方法论? 方法论是哲学术语, 简单说就是用什么样的方式来处理问题百度百科 : 方法论是普遍适用于各门具体社会科学并起到指导作用的范畴原则理论方法和手段的总和

4 函数式编程的知识结构 ( 代码即数据的编程风格 ) lambda 表达式 1 Stream2 自定义类库 3 Collectors 收集器 4 数据并行化 5

5 Lambda 表达式 Runnable noarguments=()-> System.out.println("Hello World."); noarguments.run(); Runnable multistatement=()-> { System.out.println("Hello World."); try { Integer.parseInt("AAA"); catch(numberformatexception e){ Scanner scanner=new Scanner(System.in); System.out.println(scanner.next()); ; multistatement.run(); Comparable comparable=object-> 1;// 编译器可根据上下文推断出 object 的类型 Comparator comparator=(object x,object y)->{ if(x.hashcode()>y.hashcode()){// 伪代码 return 1; return 0; ;

6 值传递和函数接口 String name="aaa"; Runnable value=()-> System.out.println("Hello World."+name); value.run(); name 就是一个既成事实的 final(effectively final) 变量 (java8) 匿名内部类要引用外部变量, 外部变量必须是 final 的 java8 放开了这个限制, 可以不用 final 修饰, 但不能多次赋值 * 函数接口 : 是只有一个抽象方法的接口 java.util.function Predicate(test) Consumer(accept) Function(apply) Supplier(get) UnaryOperator 继承 Function BinaryOperator 继承 public interface Runnable { * 未标记 FunctionalInterface 的接口也可以用于 lambda 表达式

7 JDK8 之前已有的函数式接口 java.lang.runnable java.util.concurrent.callable java.util.comparator java.lang.reflect.invocationhandler java.awt.event.actionlistener 有的接口并没有标但依然不改变它是函数接口的本质 FI 注解会检查是否只有一个待实现的方法 ( 静态方法, 默认方法除外 )-java8 特性

8 Stream Stream: 是用函数式编程方式在集合类上进行复杂操作的工具 List<String> list= new ArrayList(); list.add( A ); list.add( B ); cnt=list.stream().filter(str->str.equals( A )).count(); //Predicate for(string s:list){ if(s.equals("a")){ cnt++; 惰性求值方法 (filter)vs 及早求值方法 (count) List<String> blist=stream.of("a","b").map(string::tolowercase).collect(collectors.tolist());//function System.out.println(bList.equals(Arrays.asList("a","b"))); 区别 :Functional Interface vs Function

9 Stream Stream: 是用函数式编程方式在集合类上进行复杂操作的工具 Arrays.asList(3,1,2).stream().min(Comparator.comparing(i->i)).get();//Optional Arrays.asList(obj1,obj2).stream().max(Comparator.comparing(obj->obj.hashCode())).get(); BinaryOperator<Integer> add=(x,y)->x+y; int count=stream.of(1,2,3).reduce(add).get(); BinaryOperator<Integer> add=(x,y)->x+y; int count=stream.of(1,2,3).reduce(0,add); Map vs Reduce? Map: 将一组值转换为另一组值 Reduce: 从一组值中生成一个值

10 For example 假设要找出某些商家的商品在某个分类下的原价在 1500 以上的折扣超过 75% 的商品编号 flatmap filter filter map filter List<Integer> wareidlist=venderlist.stream().flatmap(vender -> vender.getwarelist()).filter(ware->ware.getcategory()==1).filter(ware -> ware.getprice() > 1500).filter(ware -> ware.getdiscount() > 75).map(Ware::getWareId)// 方法引用 method reference.collect(tolist());

11 自定义类库自定义可以使用 lambda 表达式的方法 public void debug(supplier<string> message){ debug(message.get()); public void debug(string message){ System.out.println(message); JAVA8 new feature: Collection stream,iterable foreach default Stream<E> stream() { return StreamSupport.stream(spliterator(), false); default void foreach(consumer<? super T> action) { Objects.requireNonNull(action); for (T t : this) { action.accept(t);

12 接口的默认方法的继承静态方法类胜于接口子类胜于父类接口继承,Walk extends Move 接口实现类,WalkImpl 接口实现类的继承 WalkImpl extends MoveImpl 多重实现类 RunImpl implements A,B Java 8 new feature:stream.of, Optional.of Optional<Integer> optional=optional.empty(); if(optional.ispresent()){ System.out.println(optional.get()); System.out.println(optional.orElse(1)); System.out.println(optional.orElseGet(()->2)); 用 Optional 类型代替 null, 鼓励程序员检查变量是否为空

13 Collectors import static java.util.stream.collectors.tolist;// 静态引入 List<Integer> wareidlist=venderlist.stream().flatmap(vender -> vender.getwarelist()).filter(ware->ware.getcategory()==1).filter(ware -> ware.getprice() > 1500).filter(ware -> ware.getdiscount() > 75).map(Ware::getWareId)// 方法引用 method reference.collect(tolist()); tocollection, toset, tomap, toconcurrentmap, maxby, averagingint, partitionby, groupingby, joining, stream has already been operated upon or closed partitionby vs groupingby 组合收集 groupingby($lambda,mapping)

14 自定义 Collector public class StringCollector implements Collector<String,StringCombiner,String> { private String append; private static final Set<Characteristics> characteristics = Collections.emptySet(); public StringCollector(String append){ public Supplier supplier() { return ()->new public BiConsumer<StringCombiner,String> accumulator() { return public BinaryOperator<StringCombiner> combiner() { return public Function<StringCombiner,String> finisher() { return public Set<Characteristics> characteristics() { return characteristics; skulist.stream().map(sku::getname).collect( new StringCollector("^") ); Since1.8 Map.computeIfAbsent Get? Put?

15 并行与并发核 1(CPU) 核 2 A 图核 1 核 2 B 图任务 1 任务 2 任务 1 任务 1 任务 2 任务 1 任务 3 任务 1 与任务 2 是并发处理任务 1 与任务 3 是并行处理任务 2 任务 2 任务 2 与任务 3 是并行处理并发但不并行并发且并行并发 : 多个任务共享时间段并行 : 多个任务同一时间发生数据并行化 : 是指将数据分成快, 为每块数据分配单独的处理单元

16 并行化操作 Stream.of(1,2,3).parallel().collect( ); List.parallelStream().collect( ); 性能好 :ArrayList, 数组,IntStream.range 性能一般 :HashSet,TreeSet 性能差 :LinkedList,Stream.iterate 无状态性能好 :map,filter,flatmap 有状态性能差 :limit,sorted,distinct int size= ; Seller[] sellers=new Seller[size]; Arrays.setAll(sellers, i -> new Seller(i,new BigDecimal(i+ Math.random()),1+i)); double ret=arrays.aslist(sellers).stream().maptodouble( seller -> seller.getprice().doublevalue() * seller.getrate()).sum(); Sequential vs Parallel 条 :0.475 vs 条 :1.132 vs 条 :9.770 vs int size= ; Seller[] sellers=new Seller[size]; Arrays.parallelSetAll(sellers, i->new Seller(i,new BigDecimal(i+ Math.random()),1+i)); double ret=arrays.aslist(sellers).parallelstream().maptodouble( seller -> seller.getprice().doublevalue() * seller.getrate()).sum();

17 THANK YOU

第2章数据类型、常量与变量

第2章数据类型、常量与变量第 2 章数据类型常量与变量在计算机程序中都是通过值 (value) 来进行运算的, 能够表示并操作值的类型为数据类型在本章里将会介绍 JavaScript 中的常量 (literal) 变量 (variable) 和数据类型 (data type) 2.1 基本数据类型 JavaScript