java.util。stream.Stream是Java 8新加入的最常用的流接口。(这并不是一个函数式接口);
获取一个流非常简单,有以下几种常用的方式获取流.
package com.Stream;
import java.util.*;
import java.util.stream.Stream;
/*
java.util。stream.Stream<T>是Java 8新加入的最常用的流接口。(这并不是一个函数式接口)
获取一个流非常简单,有以下几种常用的方式获取流;
所有的Collection结合都可以通过stream默认方法获取流;
default Stream<E> Stream()
Stream接口的静态方法of可以获取数组对应的流。
static<T> Stream<T> of (T...values)
参数是一个可变参数,那么我们就可以传递一个数组
*/
public class Demo03GetStream {
public static void main(String[] args) {
//把集合转换为Stream流
List<String> list = new ArrayList<>();
Stream<String> stream1 = list.stream();
Set<String> set = new HashSet<>();
Stream<String> stream2 = set.stream();
Map<String,String> map = new HashMap<>();
//获取键,存储到一个Set集合中
Set<String> keySet = map.keySet();
Stream<String> stream3 = keySet.stream();
//获取值,存储到一个Collection集合中
Collection<String> values = map.values();
Stream<String> stream4 = values.stream();
//获取键值对(键与值的映射关系 entrySet)
Set<Map.Entry<String, String>> entries = map.entrySet();
Stream<Map.Entry<String, String>> stream5 = entries.stream();
//把数组转换为Stream流
Stream<Integer> stream6 = Stream.of(1, 2, 3, 4, 5, 6);
//可变参数可以传递数组
Integer[] arr = {
1,2,3,4,5};
Stream<Integer> stream7 = Stream.of(arr);
String[] arr2 = {
"a","dd","cc"};
Stream<String> stream8 = Stream.of(arr2);
}
}
流模型的操作很丰富,这里介绍一些常用的API。这些方法可以被分成两种:
void forEach(Consumer<? super T> action);
package com.Stream;
import java.util.stream.Stream;
/*
Stream流中常用方法_forEach
void forEach(Consumer<? super T> action);
该方法接收一个Consumer接口函数,会将每一个流元素交给函数进行处理。
Consumer接口是一个消费型的函数式接口,可以传递Lambda表达式,消费数据
简单记:
forEach方法,用来遍历流中的数据
是一个终结方法,遍历之后就不能继续调用Stream流中的其他方法
*/
public class Dem04Stream_forEach {
public static void main(String[] args) {
//获取一个Stream流
Stream<String> stream = Stream.of("张三", "赵四", "王五", "李六", "田七");
//使用Stream流中的方法forEach对Stream流中的数据进行遍历
/* stream.forEach((String name)->{
System.out.println(name);
});*/
stream.forEach( name-> System.out.println(name));
}
}
Stream<T> filter(Predicate<? super T> predicate);
package com.Stream;
import java.util.stream.Stream;
/*
Stream流中的常用方法——filter:用于对Stream流中的数据进行过滤
Stream<T> filter(Predicate<? super T> predicate);
filter方法的参数Predicate是一个函数式接口,所以可以传递Lambda表达式,对数据进行过滤
Predicate中的抽象方法:
boolean test(T t);
*/
public class Demo05Stream_filter {
public static void main(String[] args) {
//创建一个Stream流
Stream<String> stream = Stream.of("张三丰", "张翠山", "周芷若", "赵敏", "张无忌");
//对Stream流中的元素进行过滤,只要姓张的人
Stream stream2 = stream.filter((String name)->{
return name.startsWith("张");});
//遍历stream2
stream2.forEach(name-> System.out.println(name));
/*
Stream流属于管道流,只能被消费(使用)一次
第一个Stream流调用完毕方法,数据就会流转到下一个Stream上
而这时第一个Stream流已经使用完毕,就会关闭了
所以第一个Stream流就不能调用方法了
IllegalStateException: stream has already been operated upon or closed
*/
//遍历Stream流
stream.forEach(name-> System.out.println(name));
}
}
<R> Stream<R> map(Function<? super T,? extends R> mapper);
package com.Stream;
import java.util.stream.Stream;
/*
如果需要将流中的元素映射到另一个流中,可以使用map方法。
<R> Stream<R> map(Function<? super T,? extends R> mapper);
该接口需要一个Function函数式接口参数,可以将当前流中的T类型数据转化为另一种R类型的流。
Function中的抽象方法:
R apply(T t);
*/
public class Demo06Stream_map {
public static void main(String[] args) {
//获取一个String类型的Stream流
Stream<String> stream = Stream.of("1", "2", "3", "4", "5", "6");
//使用map方法,把字符串类型的整数,转换(映射)为Integer类型的整数
Stream<Integer> stream2 = stream.map((String s)->{
return Integer.parseInt(s);
});
//遍历stream2
stream2.forEach(i-> System.out.println(i));
}
}
package com.Stream;
import java.util.ArrayList;
import java.util.stream.Stream;
/*
Stream流中常用方法_count:用于统计Stream流中元素的个数
long count();
count方法是一个终结方法,返回值是一个long类型的整数
所以不能再继续调用Stream流中的其他方法了
*/
public class Demo07Stream_count {
public static void main(String[] args) {
//获取一个Stream流
ArrayList<Integer> list = new ArrayList<>();
list.add(1);
list.add(2);
list.add(3);
list.add(4);
list.add(5);
list.add(6);
Stream<Integer> stream = list.stream();
long count = stream.count();
System.out.println(count);
}
}
Stream<T> limit(long maxSize);
package com.Stream;
import java.util.stream.Stream;
/*
Stream流中常用方法——limit:用于截取流中的元素
limit方法可以对流进行截取,只取前n个。方法签名:
Stream<T> limit(long maxSize);
参数是一个long型,如果集合当前长度大于参数则进行截取,否则不进行操作
limit方法是一个延迟方法,只是对流中的元素进行截取,返回的是一个新的流,所以可以继续调用Stream流中的其他方法
*/
public class Demo08Stream_limit {
public static void main(String[] args) {
//获取一个Stream流
String[] arr = {
"美羊羊","喜羊羊","懒羊羊","灰太狼","红太狼","小灰灰"};
Stream<String> stream = Stream.of(arr);
//使用limit方法对Stream流中的元素进行截取,只要前3个元素
Stream<String> strean2 = stream.limit(3);
//遍历stream2流
strean2.forEach(name-> System.out.println(name));
}
}
Stream<T> skip(long n);
package com.Stream;
import java.util.stream.Stream;
/*
Stream流中常用方法——skip:用于跳过元素
如果希望跳过前几个元素,可以使用skip方法获取一个截取之后的新流;
Stream<T> skip(long n);
如果流的当前长度大于n,则跳过前n个;否则将会得到一个长度为0的空流
*/
public class Demo09Stream_skip {
public static void main(String[] args) {
//获取一个Stream流
String[] arr = {
"美羊羊","喜羊羊","懒羊羊","灰太狼","红太狼","小灰灰"};
Stream<String> stream = Stream.of(arr);
//使用skip方法跳过前3个元素
Stream<String> stream2 = stream.skip(3);
//遍历stream2流
stream2.forEach(name-> System.out.println(name));
}
}
static <T> Stream<T> concat (Stream<? extends T> a,Stream <? extends T> b)
package com.Stream;
import java.util.stream.Stream;
/*
Stream流中的常用方法——concat:用于把流组合到一起
如果有两个流,希望合并成为一个流,那么可以使用静态方法concat
static <T> Stream<T> concat (Stream<? extends T> a,Stream <? extends T> b)
*/
public class Demo10Stream_concat {
public static void main(String[] args) {
//创建一个Stream流
Stream<String> stream1 = Stream.of("张三丰", "张翠山", "周芷若", "赵敏", "张无忌");
//获取一个Stream流
String[] arr = {
"美羊羊","喜羊羊","懒羊羊","灰太狼","红太狼","小灰灰"};
Stream<String> stream2 = Stream.of(arr);
//把以上两个流组合一个流
Stream<String> concat = Stream.concat(stream1, stream2);
//遍历concat
concat.forEach(name-> System.out.println(name));
}
}
文章浏览阅读1k次。通过使用ajax方法跨域请求是浏览器所不允许的,浏览器出于安全考虑是禁止的。警告信息如下:不过jQuery对跨域问题也有解决方案,使用jsonp的方式解决,方法如下:$.ajax({ async:false, url: 'http://www.mysite.com/demo.do', // 跨域URL ty..._nginx不停的xhr
文章浏览阅读2k次。关于在 Oracle 中配置 extproc 以访问 ST_Geometry,也就是我们所说的 使用空间SQL 的方法,官方文档链接如下。http://desktop.arcgis.com/zh-cn/arcmap/latest/manage-data/gdbs-in-oracle/configure-oracle-extproc.htm其实简单总结一下,主要就分为以下几个步骤。..._extproc
文章浏览阅读1.5w次。linux下没有上面的两个函数,需要使用函数 mbstowcs和wcstombsmbstowcs将多字节编码转换为宽字节编码wcstombs将宽字节编码转换为多字节编码这两个函数,转换过程中受到系统编码类型的影响,需要通过设置来设定转换前和转换后的编码类型。通过函数setlocale进行系统编码的设置。linux下输入命名locale -a查看系统支持的编码_linux c++ gbk->utf8
文章浏览阅读750次。今天准备从生产库向测试库进行数据导入,结果在imp导入的时候遇到“ IMP-00009:导出文件异常结束” 错误,google一下,发现可能有如下原因导致imp的数据太大,没有写buffer和commit两个数据库字符集不同从低版本exp的dmp文件,向高版本imp导出的dmp文件出错传输dmp文件时,文件损坏解决办法:imp时指定..._imp-00009导出文件异常结束
文章浏览阅读143次。当下是一个大数据的时代,各个行业都离不开数据的支持。因此,网络爬虫就应运而生。网络爬虫当下最为火热的是Python,Python开发爬虫相对简单,而且功能库相当完善,力压众多开发语言。本次教程我们爬取前程无忧的招聘信息来分析Python程序员需要掌握那些编程技术。首先在谷歌浏览器打开前程无忧的首页,按F12打开浏览器的开发者工具。浏览器开发者工具是用于捕捉网站的请求信息,通过分析请求信息可以了解请..._初级python程序员能力要求
文章浏览阅读7.6k次,点赞2次,收藏6次。@Service标注的bean,类名:ABDemoService查看源码后发现,原来是经过一个特殊处理:当类的名字是以两个或以上的大写字母开头的话,bean的名字会与类名保持一致public class AnnotationBeanNameGenerator implements BeanNameGenerator { private static final String C..._@service beanname
文章浏览阅读6.9w次,点赞73次,收藏463次。1.前序创建#include<stdio.h>#include<string.h>#include<stdlib.h>#include<malloc.h>#include<iostream>#include<stack>#include<queue>using namespace std;typed_二叉树的建立
文章浏览阅读7.1k次。在Asp.net上使用Excel导出功能,如果文件名出现中文,便会以乱码视之。 解决方法: fileName = HttpUtility.UrlEncode(fileName, System.Text.Encoding.UTF8);_asp.net utf8 导出中文字符乱码
文章浏览阅读2.1k次,点赞4次,收藏23次。第一次实验 词法分析实验报告设计思想词法分析的主要任务是根据文法的词汇表以及对应约定的编码进行一定的识别,找出文件中所有的合法的单词,并给出一定的信息作为最后的结果,用于后续语法分析程序的使用;本实验针对 PL/0 语言 的文法、词汇表编写一个词法分析程序,对于每个单词根据词汇表输出: (单词种类, 单词的值) 二元对。词汇表:种别编码单词符号助记符0beginb..._对pl/0作以下修改扩充。增加单词
文章浏览阅读773次。我在使用adb.exe时遇到了麻烦.我想使用与bash相同的adb.exe shell提示符,所以我决定更改默认的bash二进制文件(当然二进制文件是交叉编译的,一切都很完美)更改bash二进制文件遵循以下顺序> adb remount> adb push bash / system / bin /> adb shell> cd / system / bin> chm..._adb shell mv 权限
文章浏览阅读6.8k次,点赞12次,收藏125次。1. 单目相机标定引言相机标定已经研究多年,标定的算法可以分为基于摄影测量的标定和自标定。其中,应用最为广泛的还是张正友标定法。这是一种简单灵活、高鲁棒性、低成本的相机标定算法。仅需要一台相机和一块平面标定板构建相机标定系统,在标定过程中,相机拍摄多个角度下(至少两个角度,推荐10~20个角度)的标定板图像(相机和标定板都可以移动),即可对相机的内外参数进行标定。下面介绍张氏标定法(以下也这么称呼)的原理。原理相机模型和单应矩阵相机标定,就是对相机的内外参数进行计算的过程,从而得到物体到图像的投影_相机-投影仪标定
文章浏览阅读2.2k次。文章目录Wayland 架构Wayland 渲染Wayland的 硬件支持简 述: 翻译一篇关于和 wayland 有关的技术文章, 其英文标题为Wayland Architecture .Wayland 架构若是想要更好的理解 Wayland 架构及其与 X (X11 or X Window System) 结构;一种很好的方法是将事件从输入设备就开始跟踪, 查看期间所有的屏幕上出现的变化。这就是我们现在对 X 的理解。 内核是从一个输入设备中获取一个事件,并通过 evdev 输入_wayland