Stream体验

冷不防 2022-12-23 07:03 141阅读 0赞

## 1.流是什么 ##

*  流是Java API的新成员，它允许你以声明性方式处理数据集合（通过查询语句来表达，而不  
    是临时编写一个实现）
 *  就现在来说，你可以把它们看成遍历数据集的高级迭代器
 *  此外，流还可以透明地并行处理，你无需写任何多线程代码了

## 2.通过一个例子，来了解流的好处吧 ##

(1) 定义一个菜谱menu，记录了菜的名称，能量，是否是素菜，类型。

public class Dish { 
    
        private final String name;
        private final boolean vegetarian;
        private final int calories;
        private final Type type;
    
        public Dish(String name, boolean vegetarian, int calories, Type type) { 
            this.name = name;
            this.vegetarian = vegetarian;
            this.calories = calories;
            this.type = type;
        }
    }
        
    List<Dish> menu = Arrays.asList(
                    new Dish("pork", false, 800, Dish.Type.MEAT),
                    new Dish("beef", false, 700, Dish.Type.MEAT),
                    new Dish("chicken", false, 400, Dish.Type.MEAT),
                    new Dish("french fries", true, 530, Dish.Type.OTHER),
                    new Dish("rice", true, 350, Dish.Type.OTHER),
                    new Dish("season fruit", true, 120, Dish.Type.OTHER),
                    new Dish("pizza", true, 550, Dish.Type.OTHER),
                    new Dish("prawns", false, 300, Dish.Type.FISH),
                    new Dish("salmon", false, 450, Dish.Type.FISH));

(2) 现有个需求返回低热量的菜肴名称的，并按照卡路里排序。

### 2.1 java 7 Collections 的实现方式 ###

private static List<String> getDishNamesByCollections(List<Dish> menu) { 
            List<Dish> lowCalories = new ArrayList<>();
    
            //filter and get calories less 400
            for (Dish d : menu) { 
                if (d.getCalories() < 400)
                    lowCalories.add(d);
            }
    
            //sort
            Collections.sort(lowCalories, (d1, d2) -> Integer.compare(d1.getCalories(), d2.getCalories()));
    
            List<String> dishNameList = new ArrayList<>();
            for (Dish d : lowCalories) { 
                dishNameList.add(d.getName());
            }
            return dishNameList;
        }

### 2.2 java 8 stream的实现方式 ###

private static List<String> getDishNamesByStream(List<Dish> menu) { 
          return menu.parallelStream()
          .filter(d -> d.getCalories() < 400 )
          .sorted(comparing(Dish::getCalories)).map(Dish::getName).collect(toList());
      }

从上面可以看到stream代码简洁了很多，而且利用了forkjoinpool，让并行计算成为可能。