赞
踩
点击关注公众号,回复“1024”获取2TB学习资源!
Java现在发布的版本很快,每年两个,但是真正会被大规模使用的是三年一个的TLS版本。
每3年发布一个TLS,长期维护版本。意味着Java 8 ,Java 11, Java 17 才可能被大规模使用。
每年发布两个正式版本,分别是3月份和9月份。
在Java世界里面,面向对象还是主流思想,对于习惯了面向对象编程的开发者来说,抽象的概念并不陌生。面向对象编程是对数据进行抽象,而函数式编程是对行为进行抽象。现实世界中,数据和行为并存,程序也是如此,因此这两种编程方式我们都得学。
这种新的抽象方式还有其他好处。很多人不总是在编写性能优先的代码,对于这些人来说,函数式编程带来的好处尤为明显。程序员能编写出更容易阅读的代码——这种代码更多地表达了业务逻辑,而不是从机制上如何实现。易读的代码也易于维护、更可靠、更不容易出错。
在写回调函数和事件处理器时,程序员不必再纠缠于匿名内部类的冗繁和可读性,函数式编程让事件处理系统变得更加简单。能将函数方便地传递也让编写惰性代码变得容易,只有在真正需要的时候,才初始化变量的值。
面向对象编程是对数据进行抽象;函数式编程是对行为进行抽象。
核心思想: 使用不可变值和函数,函数对一个值进行处理,映射成另一个值。
对核心类库的改进主要包括集合类的API和新引入的流Stream。流使程序员可以站在更高的抽象层次上对集合进行操作。
lambda表达式仅能放入如下代码: 预定义使用了 @Functional 注释的函数式接口,自带一个抽象函数的方法,或者SAM(Single Abstract Method 单个抽象方法)类型。这些称为lambda表达式的目标类型,可以用作返回类型,或lambda目标代码的参数。例如,若一个方法接收Runnable、Comparable或者 Callable 接口,都有单个抽象方法,可以传入lambda表达式。类似的,如果一个方法接受声明于 java.util.function 包内的接口,例如 Predicate、Function、Consumer 或 Supplier,那么可以向其传lambda表达式。
lambda表达式内可以使用方法引用
,仅当该方法不修改lambda表达式提供的参数。本例中的lambda表达式可以换为方法引用,因为这仅是一个参数相同的简单方法调用。
- list.forEach(n -> System.out.println(n));
- list.forEach(System.out::println); // 使用方法引用
然而,若对参数有任何修改,则不能使用方法引用,而需键入完整地lambda表达式,如下所示:
list.forEach((String s) -> System.out.println("*" + s + "*"));
事实上,可以省略这里的lambda参数的类型声明,编译器可以从列表的类属性推测出来。
lambda内部可以使用静态、非静态和局部变量,这称为lambda内的变量捕获。
Lambda表达式在Java中又称为闭包或匿名函数,所以如果有同事把它叫闭包的时候,不用惊讶。
Lambda方法在编译器内部被翻译成私有方法,并派发 invokedynamic 字节码指令来进行调用。可以使用JDK中的 javap 工具来反编译class文件。使用 javap -p 或 javap -c -v 命令来看一看lambda表达式生成的字节码。大致应该长这样:
private static java.lang.Object lambda$0(java.lang.String);
lambda表达式有个限制,那就是只能引用 final 或 final 局部变量,这就是说不能在lambda内部修改定义在域外的变量。
- List<Integer> primes = Arrays.asList(new Integer[]{2, 3,5,7});
- int factor = 2;
- primes.forEach(element -> { factor++; });
Compile time error : "local variables referenced from a lambda expression must be final or effectively final" 另外,只是访问它而不作修改是可以的,如下所示:
- List<Integer> primes = Arrays.asList(new Integer[]{2, 3,5,7});
- int factor = 2;
- primes.forEach(element -> { System.out.println(factor*element); });
lists.stream().filter(f -> f.getName().equals("p1"))
如上示例,这行代码并未做什么实际性的工作,filter只是描述了Stream,没有产生新的集合。
如果是多个条件组合,可以通过代码块{}
List<Person> list2 = lists.stream().filter(f -> f.getName().equals("p1")).collect(Collectors.toList());
如上示例,collect最终会从Stream产生新值,拥有终止操作。
理想方式是形成一个惰性求值的链,最后用一个及早求值的操作返回想要的结果。与建造者模式相似,建造者模式先是使用一系列操作设置属性和配置,最后调用build方法,创建对象。
每个Stream都有两种模式: 顺序执行和并行执行。
顺序流:
List <Person> people = list.getStream.collect(Collectors.toList());
并行流:
List <Person> people = list.getStream.parallel().collect(Collectors.toList());
顾名思义,当使用顺序方式去遍历时,每个item读完后再读下一个item。而使用并行去遍历时,数组会被分成多个段,其中每一个都在不同的线程中处理,然后将结果一起输出。
- List originalList = someData;
- split1 = originalList(0, mid);//将数据分小部分
- split2 = originalList(mid,end);
- new Runnable(split1.process());//小部分执行操作
- new Runnable(split2.process());
- List revisedList = split1 + split2;//将结果合并
大家对hadoop有稍微了解就知道,里面的 MapReduce 本身就是用于并行处理大数据集的软件框架,其 处理大数据的核心思想就是大而化小,分配到不同机器去运行map,最终通过reduce将所有机器的结果结合起来得到一个最终结果,与MapReduce不同,Stream则是利用多核技术可将大数据通过多核并行处理,而MapReduce则可以分布式的。
如果是多核机器,理论上并行流则会比顺序流快上一倍,下面是测试代码
- long t0 = System.nanoTime();
-
- //初始化一个范围100万整数流,求能被2整除的数字,toArray()是终点方法
-
- int a[]=IntStream.range(0, 1_000_000).filter(p -> p % 2==0).toArray();
-
- long t1 = System.nanoTime();
-
- //和上面功能一样,这里是用并行流来计算
-
- int b[]=IntStream.range(0, 1_000_000).parallel().filter(p -> p % 2==0).toArray();
-
- long t2 = System.nanoTime();
-
- //我本机的结果是serial: 0.06s, parallel 0.02s,证明并行流确实比顺序流快
-
- System.out.printf("serial: %.2fs, parallel %.2fs%n", (t1 - t0) * 1e-9, (t2 - t1) * 1e-9);
stream()
, parallelStream()
filter()
findAny()
findFirst()
sort
forEach
void
map(), reduce()
flatMap()
- 将多个Stream连接成一个Stream
collect(Collectors.toList())
distinct
, limit
count
min
, max
, summaryStatistics
看下所有API:
- new Thread( () -> System.out.println("In Java8, Lambda expression rocks !!") ).start();
-
- // 用法
- (params) -> expression
- (params) -> statement
- (params) -> { statements }
- // forEach
- List features = Arrays.asList("Lambdas", "Default Method", "Stream API", "Date and Time API");
- features.forEach(n -> System.out.println(n));
-
- // 使用Java 8的方法引用更方便,方法引用由::双冒号操作符标示,
- features.forEach(System.out::println);
构造引用
- // Supplier<Student> s = () -> new Student();
- Supplier<Student> s = Student::new;
对象::实例方法 Lambda表达式的(形参列表)与实例方法的(实参列表)类型,个数是对应
- // set.forEach(t -> System.out.println(t));
- set.forEach(System.out::println);
类名::静态方法
- // Stream<Double> stream = Stream.generate(() -> Math.random());
- Stream<Double> stream = Stream.generate(Math::random);
类名::实例方法
- // TreeSet<String> set = new TreeSet<>((s1,s2) -> s1.compareTo(s2));
- /* 这里如果使用第一句话,编译器会有提示: Can be replaced with Comparator.naturalOrder,这句话告诉我们
- String已经重写了compareTo()方法,在这里写是多此一举,这里为什么这么写,是因为为了体现下面
- 这句编译器的提示: Lambda can be replaced with method reference。好了,下面的这句就是改写成方法引用之后:
- */
- TreeSet<String> set = new TreeSet<>(String::compareTo);
常规用法
- public static void main(args[]){
- List languages = Arrays.asList("Java", "Scala", "C++", "Haskell", "Lisp");
-
- System.out.println("Languages which starts with J :");
- filter(languages, (str)->str.startsWith("J"));
-
- System.out.println("Languages which ends with a ");
- filter(languages, (str)->str.endsWith("a"));
-
- System.out.println("Print all languages :");
- filter(languages, (str)->true);
-
- System.out.println("Print no language : ");
- filter(languages, (str)->false);
-
- System.out.println("Print language whose length greater than 4:");
- filter(languages, (str)->str.length() > 4);
- }
-
- public static void filter(List names, Predicate condition) {
- names.stream().filter((name) -> (condition.test(name))).forEach((name) -> {
- System.out.println(name + " ");
- });
- }
多个Predicate组合filter
- // 可以用and()、or()和xor()逻辑函数来合并Predicate,
- // 例如要找到所有以J开始,长度为四个字母的名字,你可以合并两个Predicate并传入
- Predicate<String> startsWithJ = (n) -> n.startsWith("J");
- Predicate<String> fourLetterLong = (n) -> n.length() == 4;
- names.stream()
- .filter(startsWithJ.and(fourLetterLong))
- .forEach((n) -> System.out.print("nName, which starts with 'J' and four letter long is : " + n));
map将集合类(例如列表)元素进行转换的。还有一个 reduce() 函数可以将所有值合并成一个
- List costBeforeTax = Arrays.asList(100, 200, 300, 400, 500);
- double bill = costBeforeTax.stream().map((cost) -> cost + .12*cost).reduce((sum, cost) -> sum + cost).get();
- System.out.println("Total : " + bill);
- // 将字符串换成大写并用逗号链接起来
- List<String> G7 = Arrays.asList("USA", "Japan", "France", "Germany", "Italy", "U.K.","Canada");
- String G7Countries = G7.stream().map(x -> x.toUpperCase()).collect(Collectors.joining(", "));
- System.out.println(G7Countries);
Collectors.joining(", ")
Collectors.toList()
Collectors.toSet() ,生成set集合
Collectors.toMap(MemberModel::getUid, Function.identity())
Collectors.toMap(ImageModel::getAid, o -> IMAGE_ADDRESS_PREFIX + o.getUrl())
将多个Stream连接成一个Stream
List<Integer> result= Stream.of(Arrays.asList(1,3),Arrays.asList(5,6)).flatMap(a->a.stream()).collect(Collectors.toList());
结果: [1, 3, 5, 6]
去重
- List<LikeDO> likeDOs=new ArrayList<LikeDO>();
- List<Long> likeTidList = likeDOs.stream().map(LikeDO::getTid)
- .distinct().collect(Collectors.toList());
计总数
- int countOfAdult=persons.stream()
- .filter(p -> p.getAge() > 18)
- .map(person -> new Adult(person))
- .count();
- boolean anyStartsWithA =
- stringCollection
- .stream()
- .anyMatch((s) -> s.startsWith("a"));
-
- System.out.println(anyStartsWithA); // true
-
- boolean allStartsWithA =
- stringCollection
- .stream()
- .allMatch((s) -> s.startsWith("a"));
-
- System.out.println(allStartsWithA); // false
-
- boolean noneStartsWithZ =
- stringCollection
- .stream()
- .noneMatch((s) -> s.startsWith("z"));
-
- System.out.println(noneStartsWithZ); // true
最小值,最大值
- List<Person> lists = new ArrayList<Person>();
- lists.add(new Person(1L, "p1"));
- lists.add(new Person(2L, "p2"));
- lists.add(new Person(3L, "p3"));
- lists.add(new Person(4L, "p4"));
- Person a = lists.stream().max(Comparator.comparing(t -> t.getId())).get();
- System.out.println(a.getId());
如果比较器涉及多个条件,比较复杂,可以定制
- Person a = lists.stream().min(new Comparator<Person>() {
-
- @Override
- public int compare(Person o1, Person o2) {
- if (o1.getId() > o2.getId()) return -1;
- if (o1.getId() < o2.getId()) return 1;
- return 0;
- }
- }).get();
summaryStatistics
- //获取数字的个数、最小值、最大值、总和以及平均值
- List<Integer> primes = Arrays.asList(2, 3, 5, 7, 11, 13, 17, 19, 23, 29);
- IntSummaryStatistics stats = primes.stream().mapToInt((x) -> x).summaryStatistics();
- System.out.println("Highest prime number in List : " + stats.getMax());
- System.out.println("Lowest prime number in List : " + stats.getMin());
- System.out.println("Sum of all prime numbers : " + stats.getSum());
- System.out.println("Average of all prime numbers : " + stats.getAverage());
可以使用peek方法,peek方法可只包含一个空的方法体,只要能设置断点即可,但有些IDE不允许空,可以如下文示例,简单写一个打印逻辑。
注意,调试完后要删掉。
- List<Person> lists = new ArrayList<Person>();
- lists.add(new Person(1L, "p1"));
- lists.add(new Person(2L, "p2"));
- lists.add(new Person(3L, "p3"));
- lists.add(new Person(4L, "p4"));
- System.out.println(lists);
-
- List<Person> list2 = lists.stream()
- .filter(f -> f.getName().startsWith("p"))
- .peek(t -> {
- System.out.println(t.getName());
- })
- .collect(Collectors.toList());
- System.out.println(list2);
- /**
- * An informative annotation type used to indicate that an interface
- * type declaration is intended to be a <i>functional interface</i> as
- * defined by the Java Language Specification.
- *
- * Conceptually, a functional interface has exactly one abstract
- * method. Since {@linkplain java.lang.reflect.Method#isDefault()
- * default methods} have an implementation, they are not abstract. If
- * an interface declares an abstract method overriding one of the
- * public methods of {@code java.lang.Object}, that also does
- * <em>not</em> count toward the interface's abstract method count
- * since any implementation of the interface will have an
- * implementation from {@code java.lang.Object} or elsewhere.
- *
- * <p>Note that instances of functional interfaces can be created with
- * lambda expressions, method references, or constructor references.
- *
- * <p>If a type is annotated with this annotation type, compilers are
- * required to generate an error message unless:
- *
- * <ul>
- * <li> The type is an interface type and not an annotation type, enum, or class.
- * <li> The annotated type satisfies the requirements of a functional interface.
- * </ul>
- *
- * <p>However, the compiler will treat any interface meeting the
- * definition of a functional interface as a functional interface
- * regardless of whether or not a {@code FunctionalInterface}
- * annotation is present on the interface declaration.
- *
- * @jls 4.3.2. The Class Object
- * @jls 9.8 Functional Interfaces
- * @jls 9.4.3 Interface Method Body
- * @since 1.8
- */
- @Documented
- @Retention(RetentionPolicy.RUNTIME)
- @Target(ElementType.TYPE)
- public @interface FunctionalInterface{}
interface做注解的注解类型,被定义成java语言规范
一个被它注解的接口只能有一个抽象方法,有两种例外
第一是接口允许有实现的方法,这种实现的方法是用default关键字来标记的(java反射中java.lang.reflect.Method#isDefault()方法用来判断是否是default方法)
第二如果声明的方法和java.lang.Object中的某个方法一样,它可以不当做未实现的方法,不违背这个原则: 一个被它注解的接口只能有一个抽象方法, 比如: java public interface Comparator<T> { int compare(T o1, T o2); boolean equals(Object obj); }
如果一个类型被这个注解修饰,那么编译器会要求这个类型必须满足如下条件:
这个类型必须是一个interface,而不是其他的注解类型、枚举enum或者类class
这个类型必须满足function interface的所有要求,如你个包含两个抽象方法的接口增加这个注解,会有编译错误。
编译器会自动把满足function interface要求的接口自动识别为function interface,所以你才不需要对上面示例中的 ITest接口增加@FunctionInterface注解。
- @FunctionalInterface
- public interface IMyInterface {
- void study();
- }
-
- package com.isea.java;
- public class TestIMyInterface {
- public static void main(String[] args) {
- IMyInterface iMyInterface = () -> System.out.println("I like study");
- iMyInterface.study();
- }
- }
消费型接口:Consumer< T> void accept(T t)
有参数,无返回值的抽象方法;
“比如: map.forEach(BiConsumer<A, T>)
”
- Consumer<Person> greeter = (p) -> System.out.println("Hello, " + p.firstName);
- greeter.accept(new Person("Luke", "Skywalker"));
供给型接口:Supplier < T> T get()
无参有返回值的抽象方法;
以stream().collect(Collector<? super T, A, R> collector)
为例:
比如:
- Supplier<Person> personSupplier = Person::new;
- personSupplier.get(); // new Person
再如:
- // 调用方法
- <R, A> R collect(Collector<? super T, A, R> collector)
-
- // Collectors.toSet
- public static <T>
- Collector<T, ?, Set<T>> toSet() {
- return new CollectorImpl<>((Supplier<Set<T>>) HashSet::new, Set::add,
- (left, right) -> { left.addAll(right); return left; },
- CH_UNORDERED_ID);
- }
-
- // CollectorImpl
- private final Supplier<A> supplier;
- private final BiConsumer<A, T> accumulator;
- private final BinaryOperator<A> combiner;
- private final Function<A, R> finisher;
- private final Set<Characteristics> characteristics;
-
- CollectorImpl(Supplier<A> supplier,
- BiConsumer<A, T> accumulator,
- BinaryOperator<A> combiner,
- Function<A,R> finisher,
- Set<Characteristics> characteristics) {
- this.supplier = supplier;
- this.accumulator = accumulator;
- this.combiner = combiner;
- this.finisher = finisher;
- this.characteristics = characteristics;
- }
-
- CollectorImpl(Supplier<A> supplier,
- BiConsumer<A, T> accumulator,
- BinaryOperator<A> combiner,
- Set<Characteristics> characteristics) {
- this(supplier, accumulator, combiner, castingIdentity(), characteristics);
- }
-
- // collect()方法实现
- public final <R, A> R collect(Collector<? super P_OUT, A, R> collector) {
- A container;
- if (isParallel()
- && (collector.characteristics().contains(Collector.Characteristics.CONCURRENT))
- && (!isOrdered() || collector.characteristics().contains(Collector.Characteristics.UNORDERED))) {
- container = collector.supplier().get();
- BiConsumer<A, ? super P_OUT> accumulator = collector.accumulator();
- forEach(u -> accumulator.accept(container, u));
- }
- else {
- container = evaluate(ReduceOps.makeRef(collector));
- }
- return collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)
- ? (R) container
- : collector.finisher().apply(container);
- }
断定型接口:Predicate<T> boolean test(T t)
:有参,但是返回值类型是固定的boolean
比如: steam().filter()中参数就是Predicate
- Predicate<String> predicate = (s) -> s.length() > 0;
-
- predicate.test("foo"); // true
- predicate.negate().test("foo"); // false
-
- Predicate<Boolean> nonNull = Objects::nonNull;
- Predicate<Boolean> isNull = Objects::isNull;
-
- Predicate<String> isEmpty = String::isEmpty;
- Predicate<String> isNotEmpty = isEmpty.negate();
函数型接口: Function<T,R> R apply(T t)
有参有返回值的抽象方法;
比如: steam().map()
中参数就是Function<? super T, ? extends R>;reduce()中参数BinaryOperator<T> (ps: BinaryOperator<T> extends BiFunction<T,T,T>)
- Function<String, Integer> toInteger = Integer::valueOf;
- Function<String, String> backToString = toInteger.andThen(String::valueOf);
-
- backToString.apply("123"); // "123"
输出 年龄>25的女程序员中名字排名前3位的姓名
- javaProgrammers.stream()
- .filter((p) -> (p.getAge() > 25))
- .filter((p) -> ("female".equals(p.getGender())))
- .sorted((p, p2) -> (p.getFirstName().compareTo(p2.getFirstName())))
- .limit(3)
- //.forEach(e -> e.setSalary(e.getSalary() / 100 * 5 + e.getSalary()))//涨工资
- .forEach((p) -> System.out.printf("%s %s; ", p.getFirstName(), p.getLastName()));
工资最高的 Java programmer
- Person person = javaProgrammers
- .stream()
- .max((p, p2) -> (p.getSalary() - p2.getSalary()))
- .get()
将 Java programmers 的 first name 存放到 TreeSet
- TreeSet<String> javaDevLastName = javaProgrammers
- .stream()
- .map(Person::getLastName)
- .collect(toCollection(TreeSet::new))
计算付给 Java programmers 的所有money
- int totalSalary = javaProgrammers
- .parallelStream()
- .mapToInt(p -> p.getSalary())
- .sum();
Comparator多属性排序: 先按名字不分大小写排,再按GID倒序排,最后按年龄正序排
- public static void main(String[] args) {
- List<Person> personList = getTestList();
- personList.sort(Comparator.comparing(Person::getName, String.CASE_INSENSITIVE_ORDER)
- .thenComparing(Person::getGid, (a, b) -> b.compareTo(a))
- .thenComparingInt(Person::getAge));
- personList.stream().forEach(System.out::println);
- }
-
- public static List<Person> getTestList() {
- return Lists.newArrayList(new Person("dai", "301", 10), new Person("dai", "303", 10),
- new Person("dai", "303", 8), new Person("dai", "303", 6), new Person("dai", "303", 11),
- new Person("dai", "302", 9), new Person("zhang", "302", 9), new Person("zhang", "301", 9),
- new Person("Li", "301", 8));
- }
-
- // 输出结果
- // Person [name=dai, gid=303, age=6]
- // Person [name=dai, gid=303, age=8]
- // Person [name=dai, gid=303, age=10]
- // Person [name=dai, gid=303, age=11]
- // Person [name=dai, gid=302, age=9]
- // Person [name=dai, gid=301, age=10]
- // Person [name=Li, gid=301, age=8]
- // Person [name=zhang, gid=302, age=9]
- // Person [name=zhang, gid=301, age=9]
处理字符串
两个新的方法可在字符串类上使用: join和chars。第一个方法使用指定的分隔符,将任何数量的字符串连接为一个字符串。
- String.join(":", "foobar", "foo", "bar");
- // => foobar:foo:bar
第二个方法chars从字符串所有字符创建数据流,所以你可以在这些字符上使用流式操作。
- "foobar:foo:bar"
- .chars()
- .distinct()
- .mapToObj(c -> String.valueOf((char)c))
- .sorted()
- .collect(Collectors.joining());
- // => :abfor
不仅仅是字符串,正则表达式模式串也能受益于数据流。我们可以分割任何模式串,并创建数据流来处理它们,而不是将字符串分割为单个字符的数据流,像下面这样:
- Pattern.compile(":")
- .splitAsStream("foobar:foo:bar")
- .filter(s -> s.contains("bar"))
- .sorted()
- .collect(Collectors.joining(":"));
- // => bar:foobar
此外,正则模式串可以转换为谓词。这些谓词可以像下面那样用于过滤字符串流:
- Pattern pattern = Pattern.compile(".*@gmail\\.com");
- Stream.of("bob@gmail.com", "alice@hotmail.com")
- .filter(pattern.asPredicate())
- .count();
- // => 1
上面的模式串接受任何以@gmail.com结尾的字符串,并且之后用作Java8的Predicate来过滤电子邮件地址流。
Local Cache实现
- public class TestLocalCache {
-
- private static ConcurrentHashMap<Integer, Long> cache = new ConcurrentHashMap<>();
-
- static long fibonacci(int i) {
- if (i == 0)
- return i;
-
- if (i == 1)
- return 1;
-
- return cache.computeIfAbsent(i, (key) -> {
- System.out.println("Slow calculation of " + key);
-
- return fibonacci(i - 2) + fibonacci(i - 1);
- });
- }
-
- public static void main(String[] args) {
- // warm up
- for (int i = 0; i < 101; i++)
- System.out.println(
- "f(" + i + ") = " + fibonacci(i));
-
- // read -> cal
- long current = System.currentTimeMillis();
- System.out.println(fibonacci(100));
- System.out.println(System.currentTimeMillis()-current);
- }
- }
集合--》取元素的一个属性--》去重---》组装成List--》返回
- List<LikeDO> likeDOs=new ArrayList<LikeDO>();
- List<Long> likeTidList = likeDOs.stream().map(LikeDO::getTid)
- .distinct().collect(Collectors.toList());
集合--》按表达式过滤--》遍历、每个元系处理--》放入预先定义的集合中
- Map<String, StkProduct> newStockName2Product = Maps.newConcurrentMap();
- stockProducts.stream().filter(stkProduct -> stkProduct.enabled).forEach(stkProduct -> {
- String newName = BCConvert.bj2qj(StringUtils.replace(stkProduct.name, " ", ""));
- newStockName2Product.put(newName, stkProduct);
- });
- Set<String> qjStockNames;
- qjStockNames.stream().filter(name -> !acAutomaton.getKey2link().containsKey(name)).forEach(name -> {
- String value = "";
- StkProduct stkProduct = stockNameQj2Product.get(name);
- if (stkProduct != null) {
- value = stkProduct.name;
- }
- acAutomaton.getKey2link().put(name, value);
- });
集合--》map
- List<ImageModel> imageModelList = null;
- Map<Long, String> imagesMap = null;
- imagesMap = imageModelList.stream().collect(Collectors.toMap(ImageModel::getAid, o -> IMAGE_ADDRESS_PREFIX + o.getUrl()));
-
-
-
- Map<String, String> kvMap = postDetailCacheList.stream().collect(Collectors.toMap((detailCache) ->
- getBbsSimplePostKey(detailCache.getTid()), JSON::toJSONString));
-
-
- Map<Long, Long> pidToTid;
- List<String> pidKeyList = pidToTid.entrySet().stream().map((o) -> getKeyBbsReplyPid(o.getValue(), o.getKey())).collect(Collectors.toList());
-
DO模型---》Model模型
- List<AdDO> adDOList;
- adDOList.stream().map(adDo -> convertAdModel(adDo))
- .collect(Collectors.toList());
phones 是一个List<String>
,将相同的元素分组、归类
- List<String> phones=new ArrayList<String>();
- phones.add("a");
- phones.add("b");
- phones.add("a");
- phones.add("a");
- phones.add("c");
- phones.add("b");
- Map<String, List<String>> phoneClassify = phones.stream().collect(Collectors.groupingBy(item -> item));
- System.out.println(phoneClassify);
- 返回结果:
- {a=[a, a, a], b=[b, b], c=[c]}
为非null的值创建一个Optional。
of方法通过工厂方法创建Optional类。需要注意的是,创建对象时传入的参数不能为null。如果传入参数为null,则抛出NullPointerException 。
- //调用工厂方法创建Optional实例
- Optional<String> name = Optional.of("Sanaulla");
- //传入参数为null,抛出NullPointerException.
- Optional<String> someNull = Optional.of(null);
为指定的值创建一个Optional,如果指定的值为null,则返回一个空的Optional。
ofNullable与of方法相似,唯一的区别是可以接受参数为null的情况。示例如下:
- //下面创建了一个不包含任何值的Optional实例
- //例如,值为'null'
- Optional empty = Optional.ofNullable(null);
非常容易理解:如果值存在返回true,否则返回false。
类似下面的代码:
- //isPresent方法用来检查Optional实例中是否包含值
- if (name.isPresent()) {
- //在Optional实例内调用get()返回已存在的值
- System.out.println(name.get());//输出Sanaulla
- }
如果Optional有值则将其返回,否则抛出NoSuchElementException。
上面的示例中,get方法用来得到Optional实例中的值。下面我们看一个抛出NoSuchElementException的例子:
- //执行下面的代码会输出: No value present
- try {
- //在空的Optional实例上调用get(),抛出NoSuchElementException
- System.out.println(empty.get());
- } catch (NoSuchElementException ex) {
- System.out.println(ex.getMessage());
- }
如果Optional实例有值则为其调用consumer,否则不做处理
要理解ifPresent方法,首先需要了解Consumer类。简答地说,Consumer类包含一个抽象方法。该抽象方法对传入的值进行处理,但没有返回值。Java8支持不用接口直接通过lambda表达式传入参数。
如果Optional实例有值,调用ifPresent()可以接受接口段或lambda表达式。类似下面的代码:
- //ifPresent方法接受lambda表达式作为参数。
- //lambda表达式对Optional的值调用consumer进行处理。
- name.ifPresent((value) -> {
- System.out.println("The length of the value is: " + value.length());
- });
如果有值则将其返回,否则返回指定的其它值。
如果Optional实例有值则将其返回,否则返回orElse方法传入的参数。示例如下:
- //如果值不为null,orElse方法返回Optional实例的值。
- //如果为null,返回传入的消息。
- //输出: There is no value present!
- System.out.println(empty.orElse("There is no value present!"));
- //输出: Sanaulla
- System.out.println(name.orElse("There is some value!"));
orElseGet与orElse方法类似,区别在于得到的默认值。orElse方法将传入的字符串作为默认值,orElseGet方法可以接受Supplier接口的实现用来生成默认值。示例如下:
- //orElseGet与orElse方法类似,区别在于orElse传入的是默认值,
- //orElseGet可以接受一个lambda表达式生成默认值。
- //输出: Default Value
- System.out.println(empty.orElseGet(() -> "Default Value"));
- //输出: Sanaulla
- System.out.println(name.orElseGet(() -> "Default Value"));
如果有值则将其返回,否则抛出supplier接口创建的异常。
在orElseGet方法中,我们传入一个Supplier接口。然而,在orElseThrow中我们可以传入一个lambda表达式或方法,如果值不存在来抛出异常。示例如下:
- try {
- //orElseThrow与orElse方法类似。与返回默认值不同,
- //orElseThrow会抛出lambda表达式或方法生成的异常
-
- empty.orElseThrow(ValueAbsentException::new);
- } catch (Throwable ex) {
- //输出: No value present in the Optional instance
- System.out.println(ex.getMessage());
- }
ValueAbsentException定义如下:
- class ValueAbsentException extends Throwable {
-
- public ValueAbsentException() {
- super();
- }
-
- public ValueAbsentException(String msg) {
- super(msg);
- }
-
- @Override
- public String getMessage() {
- return "No value present in the Optional instance";
- }
- }
map方法文档说明如下:
如果有值,则对其执行调用mapping函数得到返回值。如果返回值不为null,则创建包含mapping返回值的Optional作为map方法返回值,否则返回空Optional。
map方法用来对Optional实例的值执行一系列操作。通过一组实现了Function接口的lambda表达式传入操作。如果你不熟悉Function接口,可以参考我的这篇博客。map方法示例如下:
- //map方法执行传入的lambda表达式参数对Optional实例的值进行修改。
- //为lambda表达式的返回值创建新的Optional实例作为map方法的返回值。
- Optional<String> upperName = name.map((value) -> value.toUpperCase());
- System.out.println(upperName.orElse("No value found"));
如果有值,为其执行mapping函数返回Optional类型返回值,否则返回空Optional。flatMap与map(Funtion)方法类似,区别在于flatMap中的mapper返回值必须是Optional。调用结束时,flatMap不会对结果用Optional封装。
flatMap方法与map方法类似,区别在于mapping函数的返回值不同。map方法的mapping函数返回值可以是任何类型T,而flatMap方法的mapping函数必须是Optional。
参照map函数,使用flatMap重写的示例如下:
- //flatMap与map(Function)非常类似,区别在于传入方法的lambda表达式的返回类型。
- //map方法中的lambda表达式返回值可以是任意类型,在map函数返回之前会包装为Optional。
- //但flatMap方法中的lambda表达式返回值必须是Optionl实例。
- upperName = name.flatMap((value) -> Optional.of(value.toUpperCase()));
- System.out.println(upperName.orElse("No value found"));//输出SANAULLA
filter个方法通过传入限定条件对Optional实例的值进行过滤。文档描述如下:
如果有值并且满足断言条件返回包含该值的Optional,否则返回空Optional。
读到这里,可能你已经知道如何为filter方法传入一段代码。是的,这里可以传入一个lambda表达式。对于filter函数我们应该传入实现了Predicate接口的lambda表达式。如果你不熟悉Predicate接口,可以参考这篇文章。
现在我来看看filter的各种用法,下面的示例介绍了满足限定条件和不满足两种情况:
- //filter方法检查给定的Option值是否满足某些条件。
- //如果满足则返回同一个Option实例,否则返回空Optional。
- Optional<String> longName = name.filter((value) -> value.length() > 6);
- System.out.println(longName.orElse("The name is less than 6 characters"));//输出Sanaulla
-
- //另一个例子是Optional值不满足filter指定的条件。
- Optional<String> anotherName = Optional.of("Sana");
- Optional<String> shortName = anotherName.filter((value) -> value.length() > 6);
- //输出: name长度不足6字符
- System.out.println(shortName.orElse("The name is less than 6 characters"));
一个综合例子
- public class OptionalDemo {
-
- public static void main(String[] args) {
- //创建Optional实例,也可以通过方法返回值得到。
- Optional<String> name = Optional.of("Sanaulla");
-
- //创建没有值的Optional实例,例如值为'null'
- Optional empty = Optional.ofNullable(null);
-
- //isPresent方法用来检查Optional实例是否有值。
- if (name.isPresent()) {
- //调用get()返回Optional值。
- System.out.println(name.get());
- }
-
- try {
- //在Optional实例上调用get()抛出NoSuchElementException。
- System.out.println(empty.get());
- } catch (NoSuchElementException ex) {
- System.out.println(ex.getMessage());
- }
-
- //ifPresent方法接受lambda表达式参数。
- //如果Optional值不为空,lambda表达式会处理并在其上执行操作。
- name.ifPresent((value) -> {
- System.out.println("The length of the value is: " + value.length());
- });
-
- //如果有值orElse方法会返回Optional实例,否则返回传入的错误信息。
- System.out.println(empty.orElse("There is no value present!"));
- System.out.println(name.orElse("There is some value!"));
-
- //orElseGet与orElse类似,区别在于传入的默认值。
- //orElseGet接受lambda表达式生成默认值。
- System.out.println(empty.orElseGet(() -> "Default Value"));
- System.out.println(name.orElseGet(() -> "Default Value"));
-
- try {
- //orElseThrow与orElse方法类似,区别在于返回值。
- //orElseThrow抛出由传入的lambda表达式/方法生成异常。
- empty.orElseThrow(ValueAbsentException::new);
- } catch (Throwable ex) {
- System.out.println(ex.getMessage());
- }
-
- //map方法通过传入的lambda表达式修改Optonal实例默认值。
- //lambda表达式返回值会包装为Optional实例。
- Optional<String> upperName = name.map((value) -> value.toUpperCase());
- System.out.println(upperName.orElse("No value found"));
-
- //flatMap与map(Funtion)非常相似,区别在于lambda表达式的返回值。
- //map方法的lambda表达式返回值可以是任何类型,但是返回值会包装成Optional实例。
- //但是flatMap方法的lambda返回值总是Optional类型。
- upperName = name.flatMap((value) -> Optional.of(value.toUpperCase()));
- System.out.println(upperName.orElse("No value found"));
-
- //filter方法检查Optiona值是否满足给定条件。
- //如果满足返回Optional实例值,否则返回空Optional。
- Optional<String> longName = name.filter((value) -> value.length() > 6);
- System.out.println(longName.orElse("The name is less than 6 characters"));
-
- //另一个示例,Optional值不满足给定条件。
- Optional<String> anotherName = Optional.of("Sana");
- Optional<String> shortName = anotherName.filter((value) -> value.length() > 6);
- System.out.println(shortName.orElse("The name is less than 6 characters"));
-
- }
- }
上述代码输出如下:
- Sanaulla
- No value present
- The length of the value is: 8
- There is no value present!
- Sanaulla
- Default Value
- Sanaulla
- No value present in the Optional instance
- SANAULLA
- SANAULLA
- Sanaulla
- The name is less than 6 characters
在 Java 8 中提高 Null 的安全性
假设我们有一个像这样的类层次结构:
- class Outer {
- Nested nested;
- Nested getNested() {
- return nested;
- }
- }
- class Nested {
- Inner inner;
- Inner getInner() {
- return inner;
- }
- }
- class Inner {
- String foo;
- String getFoo() {
- return foo;
- }
- }
解决这种结构的深层嵌套路径是有点麻烦的。我们必须编写一堆 null 检查来确保不会导致一个 NullPointerException:
- Outer outer = new Outer();
- if (outer != null && outer.nested != null && outer.nested.inner != null) {
- System.out.println(outer.nested.inner.foo);
- }
我们可以通过利用 Java 8 的 Optional 类型来摆脱所有这些 null 检查。map 方法接收一个 Function 类型的 lambda 表达式,并自动将每个 function 的结果包装成一个 Optional 对象。这使我们能够在一行中进行多个 map 操作。Null 检查是在底层自动处理的。
- Optional.of(new Outer())
- .map(Outer::getNested)
- .map(Nested::getInner)
- .map(Inner::getFoo)
- .ifPresent(System.out::println);
还有一种实现相同作用的方式就是通过利用一个 supplier 函数来解决嵌套路径的问题:
- Outer obj = new Outer();
- resolve(() -> obj.getNested().getInner().getFoo());
- .ifPresent(System.out::println);
调用 obj.getNested().getInner().getFoo()) 可能会抛出一个 NullPointerException 异常。在这种情况下,该异常将会被捕获,而该方法会返回 Optional.empty()。
- public static <T> Optional<T> resolve(Supplier<T> resolver) {
- try {
- T result = resolver.get();
- return Optional.ofNullable(result);
- }
- catch (NullPointerException e) {
- return Optional.empty();
- }
- }
请记住,这两个解决方案可能没有传统 null 检查那么高的性能。不过在大多数情况下不会有太大问题。
翻译: ImportNew.com - 高俊阳 译文链接: http://www.importnew.com/6675.html
一个接口A,Clazz类实现了接口A。
- public interface A {
- default void foo(){
- System.out.println("Calling A.foo()");
- }
- }
-
- public class Clazz implements A {
- public static void main(String[] args){
- Clazz clazz = new Clazz();
- clazz.foo();//调用A.foo()
- }
- }
代码是可以编译的,即使Clazz类并没有实现foo()方法。在接口A中提供了foo()方法的默认实现。
简单说,就是接口可以有实现方法,而且不需要实现类去实现其方法。只需在方法名前面加个default关键字即可。
为什么要有这个特性? 首先,之前的接口是个双刃剑,好处是面向抽象而不是面向具体编程,缺陷是,当需要修改接口时候,需要修改全部实现该接口的类,目前的java 8之前的集合框架没有foreach方法,通常能想到的解决办法是在JDK里给相关的接口添加新的方法及实现。然而,对于已经发布的版本,是没法在给接口添加新方法的同时不影响已有的实现。所以引进的默认方法。他们的目的是为了解决接口的修改与现有的实现不兼容的问题。
这一个功能特性出来后,很多同学都反应了,java 8的接口都有实现方法了,跟抽象类还有什么区别? 其实还是有的,请看下表对比。。
由于同一个方法可以从不同接口引入,自然而然的会有冲突的现象,默认方法判断冲突的规则如下:
1.一个声明在类里面的方法优先于任何默认方法(classes always win)
2.否则,则会优先选取路径最短的。
Case 1
- public interface A{
- default void aa() {
- System.out.println("A's aa");
- }
- }
- public interface B{
- default void aa() {
- System.out.println("B's aa");
- }
- }
- public static class D implements A,B{
-
- }
报错 Duplicate default methods named aa with the parameters () and () are inherited from the types DocApplication.B and DocApplication.A
如果一定要这么写呢,同时实现A,B并且使用A中aa? 可以这么写:
- public static class D implements A,B{
- @Override
- public void aa(){
- A.super.aa();
- }
- }
Case 2
- public interface A{
- default void aa() {
- System.out.println("A's aa");
- }
- }
- public interface B{
- default void aa() {
- System.out.println("B's aa");
- }
- }
- public interface C extends A, B{
- default void aa() {
- System.out.println("C's aa");
- }
- }
- public static class D implements A,B,C{
-
- }
输出 C's aa
Case 3
- public interface A{
- default void aa() {
- System.out.println("A's aa");
- }
- }
- public interface C extends A{
- default void aa() {
- System.out.println("C's aa");
- }
- }
- public static class D implements C{
-
- }
输出 C's aa
通过Case1-3可以知道它是找唯一的最短路径的default,如果是多个那么报错。
Case 4 如果想调用A的默认函数,则用到新语法X.super.m(…),下面修改C类,实现A接口,重写一个hello方法,如下所示:
- public interface A{
- default void aa() {
- System.out.println("A's aa");
- }
- }
- public class X implements A{
- @Override
- public void aa(){
- A.super.aa();
- }
- }
输出: A's aa
Case 5
- public interface A{
- default void aa() {
- System.out.println("A's aa");
- }
- }
- public interface B{
- default void aa() {
- System.out.println("B's aa");
- }
- }
- public interface C extends A,B{
- default void aa() {
- System.out.println("C's aa");
- }
- }
- public static class D implements C{
- @Override
- public void aa(){
- C.super.aa();
- }
- }
输出 C's aa 可见C.super表示的是C接口,同时D无法访问A,B的aa
通过Case 5也可以看出,C虽然有同一个两个最短路径的aa, 但是它自己有一个更高优先级的aa,所以不会报错; case 6 会报错
Case 6
- public interface A{
- default void aa() {
- System.out.println("A's aa");
- }
- }
- public interface B{
- default void aa() {
- System.out.println("B's aa");
- }
- }
- public interface C extends A,B{
- }
默认方法给予我们修改接口而不破坏原来的实现类的结构提供了便利,目前java 8的集合框架已经大量使用了默认方法来改进了,当我们最终开始使用Java 8的lambdas表达式时,提供给我们一个平滑的过渡体验。也许将来我们会在API设计中看到更多的默认方法的应用。
注解大家都知道,从java5开始加入这一特性,发展到现在已然是遍地开花,在很多框架中得到了广泛的使用,用来简化程序中的配置。那充满争议的类型注解究竟是什么? 复杂还是便捷?
1.在java 8之前,注解只能是在声明的地方所使用,比如类,方法,属性;
2.java 8里面,注解可以应用在任何地方,比如:
创建类实例
new @Interned MyObject();
类型映射
myString = (@NonNull String) str;
implements 语句中
class UnmodifiableList<T> implements @Readonly List<@Readonly T> { … }
throw exception声明
void monitorTemperature() throws @Critical TemperatureException { … }
需要注意的是,类型注解只是语法而不是语义,并不会影响java的编译时间,加载时间,以及运行时间,也就是说,编译成class文件的时候并不包含类型注解。
先看看下面代码
- Collections.emptyList().add("One");
- int i=Integer.parseInt("hello");
- System.console().readLine();
上面的代码编译是通过的,但运行是会分别报UnsupportedOperationException;NumberFormatException;NullPointerException异常,这些都是runtime error;
类型注解被用来支持在Java的程序中做强类型检查。配合插件式的check framework,可以在编译的时候检测出runtime error,以提高代码质量。这就是类型注解的作用了。
check framework是第三方工具,配合Java的类型注解效果就是1+1>2。它可以嵌入到javac编译器里面,可以配合ant和maven使用, 地址是http://types.cs.washington.edu/checker-framework/。check framework可以找到类型注解出现的地方并检查,举个简单的例子:
- import checkers.nullness.quals.*;
- public class GetStarted {
- void sample() {
- @NonNull Object ref = new Object();
- }
- }
使用javac编译上面的类
javac -processor checkers.nullness.NullnessChecker GetStarted.java
编译是通过,但如果修改成
@NonNull Object ref = null;
再次编译,则出现
- GetStarted.java:5: incompatible types.
- found : @Nullable <nulltype>
- required: @NonNull Object
- @NonNull Object ref = null;
- ^
- 1 error
如果你不想使用类型注解检测出来错误,则不需要processor,直接javac GetStarted.java是可以编译通过的,这是在java 8 with Type Annotation Support版本里面可以,但java 5,6,7版本都不行,因为javac编译器不知道@NonNull是什么东西,但check framework 有个向下兼容的解决方案,就是将类型注解nonnull用/**/注释起来,比如上面例子修改为
- import checkers.nullness.quals.*;
- public class GetStarted {
- void sample() {
- /*@NonNull*/ Object ref = null;
- }
- }
这样javac编译器就会忽略掉注释块,但用check framework里面的javac编译器同样能够检测出nonnull错误。通过类型注解+check framework我们可以看到,现在runtime error可以在编译时候就能找到。
JSR 308想要解决在Java 1.5注解中出现的两个问题:
在句法上对注解的限制: 只能把注解写在声明的地方
类型系统在语义上的限制: 类型系统还做不到预防所有的bug
JSR 308 通过如下方法解决上述两个问题:
对Java语言的句法进行扩充,允许注解出现在更多的位置上。包括: 方法接收器(method receivers,译注: 例public int size() @Readonly { … }),泛型参数,数组,类型转换,类型测试,对象创建,类型参数绑定,类继承和throws子句。其实就是类型注解,现在是java 8的一个特性
通过引入可插拔的类型系统(pluggable type systems)能够创建功能更强大的注解处理器。类型检查器对带有类型限定注解的源码进行分析,一旦发现不匹配等错误之处就会产生警告信息。其实就是check framework
对JSR308,有人反对,觉得更复杂更静态了,比如
@NotEmpty List<@NonNull String> strings = new ArrayList<@NonNull String>()>
换成动态语言为
var strings = ["one", "two"];
有人赞成,说到底,代码才是“最根本”的文档。代码中包含的注解清楚表明了代码编写者的意图。当没有及时更新或者有遗漏的时候,恰恰是注解中包含的意图信息,最容易在其他文档中被丢失。而且将运行时的错误转到编译阶段,不但可以加速开发进程,还可以节省测试时检查bug的时间。
并不是人人都喜欢这个特性,特别是动态语言比较流行的今天,所幸,java 8并不强求大家使用这个特性,反对的人可以不使用这一特性,而对代码质量有些要求比较高的人或公司可以采用JSR 308,毕竟代码才是“最基本”的文档,这句话我是赞同的。虽然代码会增多,但可以使你的代码更具有表达意义。对这个特性有何看法,大家各抒己见。。。。
允许在同一申明类型(类,属性,或方法)的多次使用同一个注解
java 8之前也有重复使用注解的解决方案,但可读性不是很好,比如下面的代码:
- public @interface Authority {
- String role();
- }
-
- public @interface Authorities {
- Authority[] value();
- }
-
- public class RepeatAnnotationUseOldVersion {
-
- @Authorities({@Authority(role="Admin"),@Authority(role="Manager")})
- public void doSomeThing(){
- }
- }
由另一个注解来存储重复注解,在使用时候,用存储注解Authorities来扩展重复注解。
我们再来看看java 8里面的做法:
- @Repeatable(Authorities.class)
- public @interface Authority {
- String role();
- }
-
- public @interface Authorities {
- Authority[] value();
- }
-
- public class RepeatAnnotationUseNewVersion {
- @Authority(role="Admin")
- @Authority(role="Manager")
- public void doSomeThing(){ }
- }
不同的地方是,创建重复注解Authority时,加上@Repeatable,指向存储注解Authorities,在使用时候,直接可以重复使用Authority注解。从上面例子看出,java 8里面做法更适合常规的思维,可读性强一点
JEP120没有太多内容,是一个小特性,仅仅是为了提高代码可读性。这次java 8对注解做了2个方面的改进(JEP 104,JEP120),相信注解会比以前使用得更加频繁了。
泛型是Java SE 1.5的新特性,泛型的本质是参数化类型,也就是说所操作的数据类型被指定为一个参数。通俗点将就是“类型的变量”。这种类型变量可以用在类、接口和方法的创建中。
理解Java泛型最简单的方法是把它看成一种便捷语法,能节省你某些Java类型转换(casting)上的操作:
List<Apple> box = new ArrayList<Apple>();box.add(new Apple());Apple apple =box.get(0);
上面的代码自身已表达的很清楚: box是一个装有Apple对象的List。get方法返回一个Apple对象实例,这个过程不需要进行类型转换。没有泛型,上面的代码需要写成这样:
Apple apple = (Apple)box.get(0);
泛型的最大优点是提供了程序的类型安全同时可以向后兼容,但也有尴尬的地方,就是每次定义时都要写明泛型的类型,这样显示指定不仅感觉有些冗长,最主要是很多程序员不熟悉泛型,因此很多时候不能够给出正确的类型参数,现在通过编译器自动推断泛型的参数类型,能够减少这样的情况,并提高代码可读性。
在以前的版本中使用泛型类型,需要在声明并赋值的时候,两侧都加上泛型类型。例如:
Map<String, String> myMap = new HashMap<String, String>();
你可能觉得:老子在声明变量的的时候已经指明了参数类型,为毛还要在初始化对象时再指定? 幸好,在Java SE 7中,这种方式得以改进,现在你可以使用如下语句进行声明并赋值:
Map<String, String> myMap = new HashMap<>(); //注意后面的"<>"
在这条语句中,编译器会根据变量声明时的泛型类型自动推断出实例化HashMap时的泛型类型。再次提醒一定要注意new HashMap后面的“<>”,只有加上这个“<>”才表示是自动类型推断,否则就是非泛型类型的HashMap,并且在使用编译器编译源代码时会给出一个警告提示。
但是: Java SE 7在创建泛型实例时的类型推断是有限制的: 只有构造器的参数化类型在上下文中被显著的声明了,才可以使用类型推断,否则不行。例如: 下面的例子在java 7无法正确编译(但现在在java8里面可以编译,因为根据方法参数来自动推断泛型的类型):
- List<String> list = new ArrayList<>();
- list.add("A");// 由于addAll期望获得Collection<? extends String>类型的参数,因此下面的语句无法通过
- list.addAll(new ArrayList<>());
java8里面泛型的目标类型推断主要2个:
1.支持通过方法上下文推断泛型目标类型
2.支持在方法调用链路当中,泛型类型推断传递到最后一个方法
让我们看看官网的例子
- class List<E> {
- static <Z> List<Z> nil() { ... };
- static <Z> List<Z> cons(Z head, List<Z> tail) { ... };
- E head() { ... }
- }
根据JEP101的特性,我们在调用上面方法的时候可以这样写
- //通过方法赋值的目标参数来自动推断泛型的类型
- List<String> l = List.nil();
- //而不是显示的指定类型
- //List<String> l = List.<String>nil();
- //通过前面方法参数类型推断泛型的类型
- List.cons(42, List.nil());
- //而不是显示的指定类型
- //List.cons(42, List.<Integer>nil());
以上是JEP101的特性内容了,Java作为静态语言的代表者,可以说类型系统相当丰富。导致类型间互相转换的问题困扰着每个java程序员,通过编译器自动推断类型的东西可以稍微缓解一下类型转换太复杂的问题。虽然说是小进步,但对于我们天天写代码的程序员,肯定能带来巨大的作用,至少心情更愉悦了。
更小的Java环境需要更少的计算资源。
一个较小的运行时环境可以更好的优化性能和启动时间。
消除未使用的代码从安全的角度总是好的。
这些打包的应用程序可以下载速度更快。
紧凑的JRE分3种,分别是compact1、compact2、compact3,他们的关系是compact1<compact2<compact3,他们包含的API如下图所示
使用javac根据profile编译应用程序
javac –bootclasspath, or javac –profile
如果不符合compact的api,则报错。
- $ javac -profile compact2 Test.java
- Test.java:7: error: ThreadMXBean is not available in profile 'compact2'
- ThreadMXBean bean = ManagementFactory.getThreadMXBean();
- ^
- Test.java:7: error: ManagementFactory is not available in profile 'compact2'
- ThreadMXBean bean = ManagementFactory.getThreadMXBean();
- ^
- 2 errors
java8新增一个工具,用来分析应用程序所依赖的profile,有三个参数比较常用 -p,-v,-r
- import java.util.Set;
- import java.util.HashSet;
-
- public class Deps {
- public static void main(String[] args) {
- System.out.println(Math.random());
- Set<String> set = new HashSet<>();
- }
- }
- ************** PROFILE ********************
- jdeps -P Deps.class
- Deps.class -> /Library/Java/JavaVirtualMachines/jdk1.8.0.jdk/Contents/Home/jre/lib/rt.jar
- <unnamed> (Deps.class)
- -> java.io compact1
- -> java.lang compact1
- -> java.util compact1
-
- ************** VERBOSE ********************
- jdeps -v Deps.class
- Deps.class -> /Library/Java/JavaVirtualMachines/jdk1.8.0.jdk/Contents/Home/jre/lib/rt.jar
- Deps (Deps.class)
- -> java.io.PrintStream
- -> java.lang.Math
- -> java.lang.Object
- -> java.lang.String
- -> java.lang.System
- -> java.util.HashSet
-
- ************** RECURSIVE ********************
- jdeps -R Deps.class
- Deps.class -> /Library/Java/JavaVirtualMachines/jdk1.8.0.jdk/Contents/Home/jre/lib/rt.jar
- <unnamed> (Deps.class)
- -> java.io
- -> java.lang
- -> java.util
- /Library/Java/JavaVirtualMachines/jdk1.8.0.jdk/Contents/Home/jre/lib/jce.jar -> /Library/Java/JavaVirtualMachines/jdk1.8.0.jdk/Contents/Home/jre/lib/rt.jar
- javax.crypto (jce.jar)
- -> java.io
- -> java.lang
- -> java.lang.reflect
- -> java.net
- -> java.nio
- -> java.security
- -> java.security.cert
- -> java.security.spec
- -> java.util
- -> java.util.concurrent
- -> java.util.jar
- -> java.util.regex
- -> java.util.zip
- -> javax.security.auth
- -> sun.security.jca JDK internal API (rt.jar)
- -> sun.security.util JDK internal API (rt.jar)
- -> sun.security.validator JDK internal API (rt.jar)
- javax.crypto.interfaces (jce.jar)
- -> java.lang
- -> java.math
- -> java.security
- javax.crypto.spec (jce.jar)
- -> java.lang
- -> java.math
- -> java.security.spec
- -> java.util
- /Library/Java/JavaVirtualMachines/jdk1.8.0.jdk/Contents/Home/jre/lib/rt.jar -> /Library/Java/JavaVirtualMachines/jdk1.8.0.jdk/Contents/Home/jre/lib/jce.jar
- java.security (rt.jar)
- -> javax.crypto JDK internal API (jce.jar)
- sun.security.util (rt.jar)
- -> javax.crypto JDK internal API (jce.jar)
- -> javax.crypto.interfaces JDK internal API (jce.jar)
- -> javax.crypto.spec JDK internal API (jce.jar)
- $ hg clone http://hg.openjdk.java.net/jdk8/jdk8/
- $ cd jdk8
- $ make images profiles :
- # Finished profiles (build time 00:00:27)
- ----- Build times -------
- Start 2013-03-17 14:47:35
- End 2013-03-17 14:58:26
- 00:00:25 corba
- 00:00:15 demos
- 00:01:50 hotspot
- 00:00:24 images
- 00:00:21 jaxp
- 00:00:31 jaxws
- 00:05:37 jdk
- 00:00:43 langtools
- 00:00:18 nashorn
- 00:00:27 profiles
- 00:10:51 TOTAL
- -------------------------
- Finished building Java(TM) for target 'images profiles'
- $ cd images
- $ ls -d *image
- j2re-compact1-image j2re-compact2-image j2re-compact3-image j2re-image j2sdk-image
如今,物联网正风行一时。我们看到大量不同的设备在市场上出现,每一种的更新速度都越来越快。java需要一个占用资源少的JRE运行环境,紧凑的JRE特性的出现,希望能带来以后的物联网的发展,甚至还是会有大量的java应用程序出现在物联网上面。目前oracle也发布了针对raspberry pi的JRE了。
另外该特性也是为java9的模块化项目做准备,模块化特性是javaer所期待的特性。他是解决业务系统复杂度的一个利器,当然OSGI也是相当的出色。但osgi对于新学者来说未免太复杂了。
Tiago Fernandez做过一次投票,选举最烂的JAVA API,排第一的EJB2.X,第二的就是日期API。
最开始的时候,Date既要承载日期信息,又要做日期之间的转换,还要做不同日期格式的显示,职责较繁杂(不懂单一职责,你妈妈知道吗? 纯属恶搞~哈哈)
后来从JDK 1.1 开始,这三项职责分开了:
- 使用Calendar类实现日期和时间字段之间转换;
- 使用DateFormat类来格式化和分析日期字符串;
- 而Date只用来承载日期和时间信息。
原有Date中的相应方法已废弃。不过,无论是Date,还是Calendar,都用着太不方便了,这是API没有设计好的地方。
坑爹的year和month
- Date date = new Date(2012,1,1);
- System.out.println(date);
- 输出Thu Feb 01 00:00:00 CST 3912
观察输出结果,year是2012+1900,而month,月份参数我不是给了1吗? 怎么输出二月(Feb)了?
应该曾有人告诉你,如果你要设置日期,应该使用 java.util.Calendar,像这样…
- Calendar calendar = Calendar.getInstance();
- calendar.set(2013, 8, 2);
这样写又不对了,calendar的month也是从0开始的,表达8月份应该用7这个数字,要么就干脆用枚举
calendar.set(2013, Calendar.AUGUST, 2);
注意上面的代码,Calendar年份的传值不需要减去1900(当然月份的定义和Date还是一样),这种不一致真是让人抓狂!
有些人可能知道,Calendar相关的API是IBM捐出去的,所以才导致不一致。
java.util.Date与java.util.Calendar中的所有属性都是可变的
下面的代码,计算两个日期之间的天数….
- public static void main(String[] args) {
- Calendar birth = Calendar.getInstance();
- birth.set(1975, Calendar.MAY, 26);
- Calendar now = Calendar.getInstance();
- System.out.println(daysBetween(birth, now));
- System.out.println(daysBetween(birth, now)); // 显示 0?
- }
-
- public static long daysBetween(Calendar begin, Calendar end) {
- long daysBetween = 0;
- while(begin.before(end)) {
- begin.add(Calendar.DAY_OF_MONTH, 1);
- daysBetween++;
- }
- return daysBetween;
- }
daysBetween有点问题,如果连续计算两个Date实例的话,第二次会取得0,因为Calendar状态是可变的,考虑到重复计算的场合,最好复制一个新的Calendar
- public static long daysBetween(Calendar begin, Calendar end) {
- Calendar calendar = (Calendar) begin.clone(); // 复制
- long daysBetween = 0;
- while(calendar.before(end)) {
- calendar.add(Calendar.DAY_OF_MONTH, 1);
- daysBetween++;
- }
- return daysBetween;
- }
SimpleDateTimeFormat是非线程安全的。
Java 8仍然延用了ISO的日历体系,并且与它的前辈们不同,java.time包中的类是不可变且线程安全的。新的时间及日期API位于java.time包中,下面是里面的一些关键的类:
Instant——它代表的是时间戳
LocalDate——不包含具体时间的日期,比如2014-01-14。它可以用来存储生日,周年纪念日,入职日期等。
LocalTime——它代表的是不含日期的时间
LocalDateTime——它包含了日期及时间,不过还是没有偏移信息或者说时区。
ZonedDateTime——这是一个包含时区的完整的日期时间,偏移量是以UTC/格林威治时间为基准的。
新的库还增加了ZoneOffset及Zoned,可以为时区提供更好的支持。有了新的DateTimeFormatter之后日期的解析及格式化也变得焕然一新了。
该包的API提供了大量相关的方法,这些方法一般有一致的方法前缀:
of: 静态工厂方法。
parse: 静态工厂方法,关注于解析。
get: 获取某些东西的值。
is: 检查某些东西的是否是true。
with: 不可变的setter等价物。
plus: 加一些量到某个对象。
minus: 从某个对象减去一些量。
to: 转换到另一个类型。
at: 把这个对象与另一个对象组合起来,例如: date.atTime(time)。
- public class TimeIntroduction {
- public static void testClock() throws InterruptedException {
- //时钟提供给我们用于访问某个特定 时区的 瞬时时间、日期 和 时间的。
- Clock c1 = Clock.systemUTC(); //系统默认UTC时钟(当前瞬时时间 System.currentTimeMillis())
- System.out.println(c1.millis()); //每次调用将返回当前瞬时时间(UTC)
- Clock c2 = Clock.systemDefaultZone(); //系统默认时区时钟(当前瞬时时间)
- Clock c31 = Clock.system(ZoneId.of("Europe/Paris")); //巴黎时区
- System.out.println(c31.millis()); //每次调用将返回当前瞬时时间(UTC)
- Clock c32 = Clock.system(ZoneId.of("Asia/Shanghai"));//上海时区
- System.out.println(c32.millis());//每次调用将返回当前瞬时时间(UTC)
- Clock c4 = Clock.fixed(Instant.now(), ZoneId.of("Asia/Shanghai"));//固定上海时区时钟
- System.out.println(c4.millis());
- Thread.sleep(1000);
- System.out.println(c4.millis()); //不变 即时钟时钟在那一个点不动
- Clock c5 = Clock.offset(c1, Duration.ofSeconds(2)); //相对于系统默认时钟两秒的时钟
- System.out.println(c1.millis());
- System.out.println(c5.millis());
- }
- public static void testInstant() {
- //瞬时时间 相当于以前的System.currentTimeMillis()
- Instant instant1 = Instant.now();
- System.out.println(instant1.getEpochSecond());//精确到秒 得到相对于1970-01-01 00:00:00 UTC的一个时间
- System.out.println(instant1.toEpochMilli()); //精确到毫秒
- Clock clock1 = Clock.systemUTC(); //获取系统UTC默认时钟
- Instant instant2 = Instant.now(clock1);//得到时钟的瞬时时间
- System.out.println(instant2.toEpochMilli());
- Clock clock2 = Clock.fixed(instant1, ZoneId.systemDefault()); //固定瞬时时间时钟
- Instant instant3 = Instant.now(clock2);//得到时钟的瞬时时间
- System.out.println(instant3.toEpochMilli());//equals instant1
- }
- public static void testLocalDateTime() {
- //使用默认时区时钟瞬时时间创建 Clock.systemDefaultZone() -->即相对于 ZoneId.systemDefault()默认时区
- LocalDateTime now = LocalDateTime.now();
- System.out.println(now);
- //自定义时区
- LocalDateTime now2 = LocalDateTime.now(ZoneId.of("Europe/Paris"));
- System.out.println(now2);//会以相应的时区显示日期
- //自定义时钟
- Clock clock = Clock.system(ZoneId.of("Asia/Dhaka"));
- LocalDateTime now3 = LocalDateTime.now(clock);
- System.out.println(now3);//会以相应的时区显示日期
- //不需要写什么相对时间 如java.util.Date 年是相对于1900 月是从0开始
- //2013-12-31 23:59
-
- LocalDateTime d1 = LocalDateTime.of(2013, 12, 31, 23, 59);
- //年月日 时分秒 纳秒
- LocalDateTime d2 = LocalDateTime.of(2013, 12, 31, 23, 59, 59, 11);
- //使用瞬时时间 + 时区
- Instant instant = Instant.now();
- LocalDateTime d3 = LocalDateTime.ofInstant(Instant.now(), ZoneId.systemDefault());
- System.out.println(d3);
-
- //解析String--->LocalDateTime
- LocalDateTime d4 = LocalDateTime.parse("2013-12-31T23:59");
- System.out.println(d4);
- LocalDateTime d5 = LocalDateTime.parse("2013-12-31T23:59:59.999");//999毫秒 等价于999000000纳秒
- System.out.println(d5);
-
- //使用DateTimeFormatter API 解析 和 格式化
- DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm:ss");
- LocalDateTime d6 = LocalDateTime.parse("2013/12/31 23:59:59", formatter);
- System.out.println(formatter.format(d6));
-
- //时间获取
- System.out.println(d6.getYear());
- System.out.println(d6.getMonth());
- System.out.println(d6.getDayOfYear());
- System.out.println(d6.getDayOfMonth());
- System.out.println(d6.getDayOfWeek());
- System.out.println(d6.getHour());
- System.out.println(d6.getMinute());
- System.out.println(d6.getSecond());
- System.out.println(d6.getNano());
-
- //时间增减
- LocalDateTime d7 = d6.minusDays(1);
- LocalDateTime d8 = d7.plus(1, IsoFields.QUARTER_YEARS);
- //LocalDate 即年月日 无时分秒
- //LocalTime即时分秒 无年月日
- //API和LocalDateTime类似就不演示了
-
- // 两个日期是否相等
- System.out.println(d1.equals(d2));
-
- // MonthDay - 用来检查生日
- LocalDate dateOfBirth = LocalDate.of(2010, 01, 14);
- MonthDay birthday = MonthDay.of(dateOfBirth.getMonth(), dateOfBirth.getDayOfMonth());
- MonthDay currentMonthDay = MonthDay.from(today);
- System.out.println(currentMonthDay.equals(birthday));
-
- // YearMonth - 用来检查信用卡过期
- YearMonth currentYearMonth = YearMonth.now(); System.out.printf("Days in month year %s: %d%n", currentYearMonth, currentYearMonth.lengthOfMonth());
- YearMonth creditCardExpiry = YearMonth.of(2018, Month.FEBRUARY);
- System.out.printf("Your credit card expires on %s %n", creditCardExpiry);
-
- // 判断闰年 - LocalDate类有一个isLeapYear()的方法
- System.out.println(dateOfBirth.isLeapYear());
- }
- public static void testZonedDateTime() {
- //即带有时区的date-time 存储纳秒、时区和时差(避免与本地date-time歧义)。
- //API和LocalDateTime类似,只是多了时差(如2013-12-20T10:35:50.711+08:00[Asia/Shanghai])
- ZonedDateTime now = ZonedDateTime.now();
- System.out.println(now);
- ZonedDateTime now2 = ZonedDateTime.now(ZoneId.of("Europe/Paris"));
- System.out.println(now2);
- //其他的用法也是类似的 就不介绍了
- ZonedDateTime z1 = ZonedDateTime.parse("2013-12-31T23:59:59Z[Europe/Paris]");
- System.out.println(z1);
- }
- public static void testDuration() {
- //表示两个瞬时时间的时间段
- Duration d1 = Duration.between(Instant.ofEpochMilli(System.currentTimeMillis() - 12323123), Instant.now());
- //得到相应的时差
- System.out.println(d1.toDays());
- System.out.println(d1.toHours());
- System.out.println(d1.toMinutes());
- System.out.println(d1.toMillis());
- System.out.println(d1.toNanos());
- //1天时差 类似的还有如ofHours()
- Duration d2 = Duration.ofDays(1);
- System.out.println(d2.toDays());
- }
- public static void testChronology() {
- //提供对java.util.Calendar的替换,提供对年历系统的支持
- Chronology c = HijrahChronology.INSTANCE;
- ChronoLocalDateTime d = c.localDateTime(LocalDateTime.now());
- System.out.println(d);
- }
- /**
- * 新旧日期转换
- */
- public static void testNewOldDateConversion(){
- Instant instant=new Date().toInstant();
- Date date=Date.from(instant);
- System.out.println(instant);
- System.out.println(date);
- }
- public static void main(String[] args) throws InterruptedException {
- testClock();
- testInstant();
- testLocalDateTime();
- testZonedDateTime();
- testDuration();
- testChronology();
- testNewOldDateConversion();
- }
- }
日期与时间处理API,在各种语言中,可能都只是个不起眼的API,如果你没有较复杂的时间处理需求,可能只是利用日期与时间处理API取得系统时间,简单做些显示罢了,然而如果认真看待日期与时间,其复杂程度可能会远超过你的想象,天文、地理、历史、政治、文化等因素,都会影响到你对时间的处理。所以在处理时间上,最好选用JSR310(如果你用java8的话就实现310了),或者Joda-Time。
不止是java面临时间处理的尴尬,其他语言同样也遇到过类似的问题,比如
Arrow: Python 中更好的日期与时间处理库
Moment.js: JavaScript 中的日期库
Noda-Time: .NET 阵营的 Joda-Time 的复制
看完了这些例子后,我相信你已经对Java 8这套新的时间日期API有了一定的了解了。现在我们来回顾下关于这个新的API的一些关键的要素。
它提供了javax.time.ZoneId用来处理时区。
它提供了LocalDate与LocalTime类 Java 8中新的时间与日期API中的所有类都是不可变且线程安全的,这与之前的Date与Calendar API中的恰好相反,那里面像java.util.Date以及SimpleDateFormat这些关键的类都不是线程安全的。
新的时间与日期API中很重要的一点是它定义清楚了基本的时间与日期的概念,比方说,瞬时时间,持续时间,日期,时间,时区以及时间段。它们都是基于ISO日历体系的。
每个Java开发人员都应该至少了解这套新的API中的这五个类: Instant 它代表的是时间戳,比如2014-01-14T02:20:13.592Z,这可以从java.time.Clock类中获取,像这样: Instant current = Clock.system(ZoneId.of(“Asia/Tokyo”)).instant(); LocalDate 它表示的是不带时间的日期,比如2014-01-14。它可以用来存储生日,周年纪念日,入职日期等。LocalTime – 它表示的是不带日期的时间 LocalDateTime – 它包含了时间与日期,不过没有带时区的偏移量 ZonedDateTime – 这是一个带时区的完整时间,它根据UTC/格林威治时间来进行时区调整
这个库的主包是java.time,里面包含了代表日期,时间,瞬时以及持续时间的类。它有两个子package,一个是java.time.foramt,这个是什么用途就很明显了,还有一个是java.time.temporal,它能从更低层面对各个字段进行访问。
时区指的是地球上共享同一标准时间的地区。每个时区都有一个唯一标识符,同时还有一个地区/城市(Asia/Tokyo)的格式以及从格林威治时间开始的一个偏移时间。比如说,东京的偏移时间就是+09:00。OffsetDateTime类实际上包含了LocalDateTime与ZoneOffset。它用来表示一个包含格林威治时间偏移量(+/-小时: 分,比如+06:00或者 -08: 00)的完整的日期(年月日)及时间(时分秒,纳秒)。DateTimeFormatter类用于在Java中进行日期的格式化与解析。与SimpleDateFormat不同,它是不可变且线程安全的,如果需要的话,可以赋值给一个静态变量。DateTimeFormatter类提供了许多预定义的格式器,你也可以自定义自己想要的格式。当然了,根据约定,它还有一个parse()方法是用于将字符串转换成日期的,如果转换期间出现任何错误,它会抛出DateTimeParseException异常。类似的,DateFormatter类也有一个用于格式化日期的format()方法,它出错的话则会抛出DateTimeException异常。
再说一句,“MMM d yyyy”与“MMm dd yyyy”这两个日期格式也略有不同,前者能识别出”Jan 2 2014″与”Jan 14 2014″这两个串,而后者如果传进来的是”Jan 2 2014″则会报错,因为它期望月份处传进来的是两个字符。为了解决这个问题,在天为个位数的情况下,你得在前面补0,比如”Jan 2 2014″应该改为”Jan 02 2014″。
跟java在服务器端和web端成绩相比,桌面一直是java的软肋,于是Sun公司在2008年推出JavaFX,弥补桌面软件的缺陷,请看下图JavaFX一路走过来的改进。
从上图看出,一开始推出时候,开发者需使用一种名为JavaFX Script的静态的、声明式的编程语言来开发JavaFX应用程序。因为JavaFX Script将会被编译为Java bytecode,程序员可以使用Java代码代替。
JavaFX 2.0之后的版本摒弃了JavaFX Script语言,而作为一个Java API来使用。因此使用JavaFX平台实现的应用程序将直接通过标准Java代码来实现。
JavaFX 2.0 包含非常丰富的 UI 控件、图形和多媒体特性用于简化可视化应用的开发,WebView可直接在应用中嵌入网页;另外 2.0 版本允许使用 FXML 进行 UI 定义,这是一个脚本化基于 XML 的标识语言。
从JDK 7u6开始,JavaFx就与JDK捆绑在一起了,JavaFX团队称,下一个版本将是8.0,目前所有的工作都已经围绕8.0库进行。这是因为JavaFX将捆绑在Java 8中,因此该团队决定跳过几个版本号,迎头赶上Java 8。
新的Modena主题来替换原来的Caspian主题。不过在Application的start()方法中,可以通过setUserAgentStylesheet(STYLESHEET_CASPIAN)来继续使用Caspian主题。
参考http://fxexperience.com/2013/03/modena-theme-update/
在JavaFX8中提供了3D图像处理API,包括Shape3D (Box, Cylinder, MeshView, Sphere子类),SubScene, Material, PickResult, LightBase (AmbientLight 和PointLight子类),SceneAntialiasing等。Camera类也得到了更新。从JavaDoc中可以找到更多信息。
强化了富文本的支持
增加日期控件
- CSS 样式设置是 JavaFX 的一项主要特性
- CSS 已专门在私有 API 中实现(com.sun.javafx.css 软件包)
- 多种工具(例如 Scene Builder)需要 CSS 公共 API
- 开发人员将能够定义自定义 CSS 样式
Nashorn JavaScript 引擎 https://blogs.oracle.com/nashorn/entry/open_for_business
WebSocket http://javafx-jira.kenai.com/browse/RT-14947
Web Workers http://javafx-jira.kenai.com/browse/RT-9782
可视化工具,加速JavaFX图形界面的开发,下载地址
JavaFX Scene Builder如同NetBeans一般,通过拖拽的方式配置界面,待完成界面之後,保存为FXML格式文件,此文件以XML描述物件配置,再交由JavaFX程式处理,因此可減少直接以JavaFX编写界面的困難度。
JavaFX Scene Builder 2.0新增JavaFX Theme预览功能,菜单「Preview」→「JavaFX Theme」选择不同的主題,包括:
- Modena (FX8).
- Modena Touch (FX8).
- Modena High Contrast – Black on White (FX8).
- Modena High Contrast – White on Black (FX8).
- Modena High Contrast – Yellow on Black (FX8).
- Caspian (FX2).
- Caspian Embedded (FX2).
- Caspian Embedded QVGA (FX2).
2048虽然不像前段时间那么火了,但个人还是非常喜欢玩2048,空闲时间都忍不住来一发,感谢 Gabriele Cirulli 发明了这了不起 (并且会上瘾)的2048游戏,因为是用MIT协议开源出来,各种语言版本的2048游戏横空出世,下图是用JavaFX 8来开发的一款2048。
所用到的技术
- Lambda expressions
- Stream API
- JavaFX 8
- JavaFX CSS basics
- JavaFX animationsfx2048相关类的说明
- Game2048,游戏主类
- GameManager,包含游戏界面布局(Board)以及Grid的操作(GridOperator)
- Board,包含labels ,分数,grid ,Tile
- Tile,游戏中的数字块
- GridOperator,Grid操作类
- Location,Direction 位置帮助类
- RecordManager,SessionManager,纪录游戏分数,会话类
比起AWT和SWING,JavaFX的优势很明显,各大主流IDE已经支持JavaFX的开发了,最佳的工具莫过于NetBeans,且随着lambda带来的好处,JavaFX的事件处理简洁了不少,以前需要写匿名函数类。另外JavaFX开源以来,JavaFX的生态环境也越来越活跃了,包括各种教程,嵌入式尝试,还有一些开源项目,比如: ControlsFX,JRebirth,DataFX Flow,mvvmFX,TestFX 等等。还有JavaFX是可以运行在Android和ios上面,这个很赞!
好了,总结到这里也差不多了,在RIA平台上面,有HTML5、Flex和微软的Sliverlight,JavaFX能否表现优秀,在于大家的各位,只要我们多用JavaFX,那么JavaFX也会越来越优秀,任何语言都是这样, THE END .
PermGen space的全称是Permanent Generation space,是指内存的永久保存区域,说说为什么会内存益出: 这一部分用于存放Class和Meta的信息,Class在被 Load的时候被放入PermGen space区域,它和和存放Instance的Heap区域不同,所以如果你的APP会LOAD很多CLASS的话,就很可能出现PermGen space错误。这种错误常见在web服务器对JSP进行pre compile的时候。
JVM 种类有很多,比如 Oralce-Sun Hotspot, Oralce JRockit, IBM J9, Taobao JVM(淘宝好样的!)等等。当然武林盟主是Hotspot了,这个毫无争议。需要注意的是,PermGen space是Oracle-Sun Hotspot才有,JRockit以及J9是没有这个区域。
JDK8 HotSpot JVM 将移除永久区,使用本地内存来存储类元数据信息并称之为: 元空间(Metaspace);这与Oracle JRockit 和IBM JVM’s很相似,如下图所示。
这意味着不会再有java.lang.OutOfMemoryError: PermGen问题,也不再需要你进行调优及监控内存空间的使用……但请等等,这么说还为时过早。在默认情况下,这些改变是透明的,接下来我们的展示将使你知道仍然要关注类元数据内存的占用。请一定要牢记,这个新特性也不能神奇地消除类和类加载器导致的内存泄漏。
java8中metaspace总结如下:
PermGen 空间的状况
这部分内存空间将全部移除。
JVM的参数: PermSize 和 MaxPermSize 会被忽略并给出警告(如果在启用时设置了这两个参数)。
Metaspace 内存分配模型
大部分类元数据都在本地内存中分配。
用于描述类元数据的“klasses”已经被移除。
Metaspace 容量
默认情况下,类元数据只受可用的本地内存限制(容量取决于是32位或是64位操作系统的可用虚拟内存大小)。
新参数(MaxMetaspaceSize)用于限制本地内存分配给类元数据的大小。如果没有指定这个参数,元空间会在运行时根据需要动态调整。
Metaspace 垃圾回收
对于僵死的类及类加载器的垃圾回收将在元数据使用达到“MaxMetaspaceSize”参数的设定值时进行。
适时地监控和调整元空间对于减小垃圾回收频率和减少延时是很有必要的。持续的元空间垃圾回收说明,可能存在类、类加载器导致的内存泄漏或是大小设置不合适。
Java 堆内存的影响
一些杂项数据已经移到Java堆空间中。升级到JDK8之后,会发现Java堆 空间有所增长。
Metaspace 监控
元空间的使用情况可以从HotSpot1.8的详细GC日志输出中得到。
Jstat 和 JVisualVM两个工具,在使用b75版本进行测试时,已经更新了,但是还是能看到老的PermGen空间的出现。
前面已经从理论上充分说明,下面让我们通过“泄漏”程序进行新内存空间的观察……
为了更好地理解Metaspace内存空间的运行时行为,
将进行以下几种场景的测试:
使用JDK1.7运行Java程序,监控并耗尽默认设定的85MB大小的PermGen内存空间。
使用JDK1.8运行Java程序,监控新Metaspace内存空间的动态增长和垃圾回收过程。
使用JDK1.8运行Java程序,模拟耗尽通过“MaxMetaspaceSize”参数设定的128MB大小的Metaspace内存空间。
首先建立了一个模拟PermGen OOM的代码
- public class ClassA {
- public void method(String name) {
- // do nothing
- }
- }
上面是一个简单的ClassA,把他编译成class字节码放到D: /classes下面,测试代码中用URLClassLoader来加载此类型上面类编译成class
- /**
- * 模拟PermGen OOM
- * @author benhail
- */
- public class OOMTest {
- public static void main(String[] args) {
- try {
- //准备url
- URL url = new File("D:/classes").toURI().toURL();
- URL[] urls = {url};
- //获取有关类型加载的JMX接口
- ClassLoadingMXBean loadingBean = ManagementFactory.getClassLoadingMXBean();
- //用于缓存类加载器
- List<ClassLoader> classLoaders = new ArrayList<ClassLoader>();
- while (true) {
- //加载类型并缓存类加载器实例
- ClassLoader classLoader = new URLClassLoader(urls);
- classLoaders.add(classLoader);
- classLoader.loadClass("ClassA");
- //显示数量信息(共加载过的类型数目,当前还有效的类型数目,已经被卸载的类型数目)
- System.out.println("total: " + loadingBean.getTotalLoadedClassCount());
- System.out.println("active: " + loadingBean.getLoadedClassCount());
- System.out.println("unloaded: " + loadingBean.getUnloadedClassCount());
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
虚拟机器参数设置如下: -verbose -verbose:gc
设置-verbose参数是为了获取类型加载和卸载的信息
设置-verbose:gc是为了获取垃圾收集的相关信息
Java1.7的PermGen默认空间为85 MB(或者可以通过-XX:MaxPermSize=XXXm指定)
可以从上面的JVisualVM的截图看出: 当加载超过6万个类之后,PermGen被耗尽。我们也能通过程序和GC的输出观察耗尽的过程。
程序输出(摘取了部分)
- ......
- [Loaded ClassA from file:/D:/classes/]
- total: 64887
- active: 64887
- unloaded: 0
- [GC 245041K->213978K(536768K), 0.0597188 secs]
- [Full GC 213978K->211425K(644992K), 0.6456638 secs]
- [GC 211425K->211425K(656448K), 0.0086696 secs]
- [Full GC 211425K->211411K(731008K), 0.6924754 secs]
- [GC 211411K->211411K(726528K), 0.0088992 secs]
- ...............
- java.lang.OutOfMemoryError: PermGen space
Java的Metaspace空间: 不受限制 (默认)
从上面的截图可以看到,JVM Metaspace进行了动态扩展,本地内存的使用由20MB增长到646MB,以满足程序中不断增长的类数据内存占用需求。我们也能观察到JVM的垃圾回收事件—试图销毁僵死的类或类加载器对象。但是,由于我们程序的泄漏,JVM别无选择只能动态扩展Metaspace内存空间。程序加载超过10万个类,而没有出现OOM事件。
Java的Metaspace空间: 128MB(-XX:MaxMetaspaceSize=128m)
可以从上面的JVisualVM的截图看出: 当加载超过2万个类之后,Metaspace被耗尽;与JDK1.7运行时非常相似。我们也能通过程序和GC的输出观察耗尽的过程。另一个有趣的现象是,保留的原生内存占用量是设定的最大大小两倍之多。这可能表明,如果可能的话,可微调元空间容量大小策略,来避免本地内存的浪费。
从Java程序的输出中看到如下异常。
- [Loaded ClassA from file:/D:/classes/]
- total: 21393
- active: 21393
- unloaded: 0
- [GC (Metadata GC Threshold) 64306K->57010K(111616K), 0.0145502 secs]
- [Full GC (Metadata GC Threshold) 57010K->56810K(122368K), 0.1068084 secs]
- java.lang.OutOfMemoryError: Metaspace
在设置了MaxMetaspaceSize的情况下,该空间的内存仍然会耗尽,进而引发“java.lang.OutOfMemoryError: Metadata space”错误。因为类加载器的泄漏仍然存在,而通常Java又不希望无限制地消耗本机内存,因此设置一个类似于MaxPermSize的限制看起来也是合理的。
之前不管是不是需要,JVM都会吃掉那块空间……如果设置得太小,JVM会死掉;如果设置得太大,这块内存就被JVM浪费了。理论上说,现在你完全可以不关注这个,因为JVM会在运行时自动调校为“合适的大小”;
提高Full GC的性能,在Full GC期间,Metadata到Metadata pointers之间不需要扫描了,别小看这几纳秒时间;
隐患就是如果程序存在内存泄露,像OOMTest那样,不停的扩展metaspace的空间,会导致机器的内存不足,所以还是要有必要的调试和监控。
在java5之前,实现同步主要是使用synchronized。它是Java语言的关键字,当它用来修饰一个方法或者一个代码块的时候,能够保证在同一时刻最多只有一个线程执行该段代码。
有四种不同的同步块:
- 实例方法
- 静态方法
- 实例方法中的同步块
- 静态方法中的同步块
大家对此应该不陌生,所以不多讲了,以下是代码示例
- synchronized(this)
- // do operation
- }
小结: 在多线程并发编程中Synchronized一直是元老级角色,很多人都会称呼它为重量级锁,但是随着Java SE1.6对Synchronized进行了各种优化之后,性能上也有所提升。
- rwlock.writeLock().lock();
- try {
- // do operation
- } finally {
- rwlock.writeLock().unlock();
- }
它是Java 5在java.util.concurrent.locks新增的一个API。
Lock是一个接口,核心方法是lock(),unlock(),tryLock(),实现类有ReentrantLock, ReentrantReadWriteLock.ReadLock, ReentrantReadWriteLock.WriteLock;
ReentrantReadWriteLock, ReentrantLock 和synchronized锁都有相同的内存语义。
与synchronized不同的是,Lock完全用Java写成,在java这个层面是无关JVM实现的。Lock提供更灵活的锁机制,很多synchronized 没有提供的许多特性,比如锁投票,定时锁等候和中断锁等候,但因为lock是通过代码实现的,要保证锁定一定会被释放,就必须将unLock()放到finally{}中
下面是Lock的一个代码示例
- class Point {
- private double x, y;
- private final StampedLock sl = new StampedLock();
- void move(double deltaX, double deltaY) { // an exclusively locked method
- long stamp = sl.writeLock();
- try {
- x += deltaX;
- y += deltaY;
- } finally {
- sl.unlockWrite(stamp);
- }
- }
- //下面看看乐观读锁案例
- double distanceFromOrigin() { // A read-only method
- long stamp = sl.tryOptimisticRead(); //获得一个乐观读锁
- double currentX = x, currentY = y; //将两个字段读入本地局部变量
- if (!sl.validate(stamp)) { //检查发出乐观读锁后同时是否有其他写锁发生?
- stamp = sl.readLock(); //如果没有,我们再次获得一个读悲观锁
- try {
- currentX = x; // 将两个字段读入本地局部变量
- currentY = y; // 将两个字段读入本地局部变量
- } finally {
- sl.unlockRead(stamp);
- }
- }
- return Math.sqrt(currentX * currentX + currentY * currentY);
- }
- //下面是悲观读锁案例
- void moveIfAtOrigin(double newX, double newY) { // upgrade
- // Could instead start with optimistic, not read mode
- long stamp = sl.readLock();
- try {
- while (x == 0.0 && y == 0.0) { //循环,检查当前状态是否符合
- long ws = sl.tryConvertToWriteLock(stamp); //将读锁转为写锁
- if (ws != 0L) { //这是确认转为写锁是否成功
- stamp = ws; //如果成功 替换票据
- x = newX; //进行状态改变
- y = newY; //进行状态改变
- break;
- }
- else { //如果不能成功转换为写锁
- sl.unlockRead(stamp); //我们显式释放读锁
- stamp = sl.writeLock(); //显式直接进行写锁 然后再通过循环再试
- }
- }
- } finally {
- sl.unlock(stamp); //释放读锁或写锁
- }
- }
- }
小结: 比synchronized更灵活、更具可伸缩性的锁定机制,但不管怎么说还是synchronized代码要更容易书写些
它是java8在java.util.concurrent.locks新增的一个API。
ReentrantReadWriteLock 在沒有任何读写锁时,才可以取得写入锁,这可用于实现了悲观读取(Pessimistic Reading),即如果执行中进行读取时,经常可能有另一执行要写入的需求,为了保持同步,ReentrantReadWriteLock 的读取锁定就可派上用场。
然而,如果读取执行情况很多,写入很少的情况下,使用 ReentrantReadWriteLock 可能会使写入线程遭遇饥饿(Starvation)问题,也就是写入线程吃吃无法竞争到锁定而一直处于等待状态。
StampedLock控制锁有三种模式(写,读,乐观读),一个StampedLock状态是由版本和模式两个部分组成,锁获取方法返回一个数字作为票据stamp,它用相应的锁状态表示并控制访问,数字0表示没有写锁被授权访问。在读锁上分为悲观锁和乐观锁。
所谓的乐观读模式,也就是若读的操作很多,写的操作很少的情况下,你可以乐观地认为,写入与读取同时发生几率很少,因此不悲观地使用完全的读取锁定,程序可以查看读取资料之后,是否遭到写入执行的变更,再采取后续的措施(重新读取变更信息,或者抛出异常) ,这一个小小改进,可大幅度提高程序的吞吐量!!
下面是java doc提供的StampedLock一个例子
- class Point {
- private double x, y;
- private final StampedLock sl = new StampedLock();
- void move(double deltaX, double deltaY) { // an exclusively locked method
- long stamp = sl.writeLock();
- try {
- x += deltaX;
- y += deltaY;
- } finally {
- sl.unlockWrite(stamp);
- }
- }
- //下面看看乐观读锁案例
- double distanceFromOrigin() { // A read-only method
- long stamp = sl.tryOptimisticRead(); //获得一个乐观读锁
- double currentX = x, currentY = y; //将两个字段读入本地局部变量
- if (!sl.validate(stamp)) { //检查发出乐观读锁后同时是否有其他写锁发生?
- stamp = sl.readLock(); //如果没有,我们再次获得一个读悲观锁
- try {
- currentX = x; // 将两个字段读入本地局部变量
- currentY = y; // 将两个字段读入本地局部变量
- } finally {
- sl.unlockRead(stamp);
- }
- }
- return Math.sqrt(currentX * currentX + currentY * currentY);
- }
- //下面是悲观读锁案例
- void moveIfAtOrigin(double newX, double newY) { // upgrade
- // Could instead start with optimistic, not read mode
- long stamp = sl.readLock();
- try {
- while (x == 0.0 && y == 0.0) { //循环,检查当前状态是否符合
- long ws = sl.tryConvertToWriteLock(stamp); //将读锁转为写锁
- if (ws != 0L) { //这是确认转为写锁是否成功
- stamp = ws; //如果成功 替换票据
- x = newX; //进行状态改变
- y = newY; //进行状态改变
- break;
- }
- else { //如果不能成功转换为写锁
- sl.unlockRead(stamp); //我们显式释放读锁
- stamp = sl.writeLock(); //显式直接进行写锁 然后再通过循环再试
- }
- }
- } finally {
- sl.unlock(stamp); //释放读锁或写锁
- }
- }
- }
小结:
StampedLock要比ReentrantReadWriteLock更加廉价,也就是消耗比较小。
是和ReadWritLock相比,在一个线程情况下,是读速度其4倍左右,写是1倍。
下图是六个线程情况下,读性能是其几十倍,写性能也是近10倍左右:
synchronized是在JVM层面上实现的,不但可以通过一些监控工具监控synchronized的锁定,而且在代码执行时出现异常,JVM会自动释放锁定;
ReentrantLock、ReentrantReadWriteLock,、StampedLock都是对象层面的锁定,要保证锁定一定会被释放,就必须将unLock()放到finally{}中;
StampedLock 对吞吐量有巨大的改进,特别是在读线程越来越多的场景下;
StampedLock有一个复杂的API,对于加锁操作,很容易误用其他方法;
当只有少量竞争者的时候,synchronized是一个很好的通用的锁实现;
当线程增长能够预估,ReentrantLock是一个很好的通用的锁实现;
StampedLock 可以说是Lock的一个很好的补充,吞吐量以及性能上的提升足以打动很多人了,但并不是说要替代之前Lock的东西,毕竟他还是有些应用场景的,起码API比StampedLock容易入手。
Java8添加了对无符号数的额外支持。Java中的数值总是有符号的,例如,让我们来观察Integer:
int可表示最多2 ** 32个数。Java中的数值默认为有符号的,所以最后一个二进制数字表示符号(0为正数,1为负数)。所以从十进制的0开始,最大的有符号正整数为2 ** 31 - 1。
你可以通过Integer.MAX_VALUE来访问它:
- System.out.println(Integer.MAX_VALUE); // 2147483647
- System.out.println(Integer.MAX_VALUE + 1); // -2147483648
Java8添加了解析无符号整数的支持,让我们看看它如何工作:
- long maxUnsignedInt = (1l << 32) - 1;
- String string = String.valueOf(maxUnsignedInt);
- int unsignedInt = Integer.parseUnsignedInt(string, 10);
- String string2 = Integer.toUnsignedString(unsignedInt, 10);
就像你看到的那样,现在可以将最大的无符号数2 ** 32 - 1解析为整数。而且你也可以将这个数值转换回无符号数的字符串表示。
这在之前不可能使用parseInt完成,就像这个例子展示的那样:
- try {
- Integer.parseInt(string, 10);
- }
- catch (NumberFormatException e) {
- System.err.println("could not parse signed int of " + maxUnsignedInt);
- }
这个数值不可解析为有符号整数,因为它超出了最大范围2 ** 31 - 1。算术运算
Math工具类新增了一些方法来处理数值溢出。这是什么意思呢? 我们已经看到了所有数值类型都有最大值。所以当算术运算的结果不能被它的大小装下时,会发生什么呢?
- System.out.println(Integer.MAX_VALUE); // 2147483647
- System.out.println(Integer.MAX_VALUE + 1); // -2147483648
就像你看到的那样,发生了整数溢出,这通常是我们不愿意看到的。
Java8添加了严格数学运算的支持来解决这个问题。Math扩展了一些方法,它们全部以exact结尾,例如addExact。当运算结果不能被数值类型装下时,这些方法通过抛出ArithmeticException异常来合理地处理溢出。
- try {
- Math.addExact(Integer.MAX_VALUE, 1);
- }
- catch (ArithmeticException e) {
- System.err.println(e.getMessage());
- // => integer overflow
- }
当尝试通过toIntExact将长整数转换为整数时,可能会抛出同样的异常:
- try {
- Math.toIntExact(Long.MAX_VALUE);
- }
- catch (ArithmeticException e) {
- System.err.println(e.getMessage());
- // => integer overflow
- }
Files工具类首次在Java7中引入,作为NIO的一部分。JDK8 API添加了一些额外的方法,它们可以将文件用于函数式数据流。让我们深入探索一些代码示例。列出文件
Files.list方法将指定目录的所有路径转换为数据流,便于我们在文件系统的内容上使用类似filter和sorted的流操作。
- try (Stream<Path> stream = Files.list(Paths.get(""))) {
- String joined = stream
- .map(String::valueOf)
- .filter(path -> !path.startsWith("."))
- .sorted()
- .collect(Collectors.joining("; "));
- System.out.println("List: " + joined);
- }
上面的例子列出了当前工作目录的所有文件,之后将每个路径都映射为它的字符串表示。之后结果被过滤、排序,最后连接为一个字符串。如果你还不熟悉函数式数据流,你应该阅读我的Java8数据流教程。
你可能已经注意到,数据流的创建包装在try-with语句中。数据流实现了AutoCloseable,并且这里我们需要显式关闭数据流,因为它基于IO操作。
返回的数据流是DirectoryStream的封装。如果需要及时处理文件资源,就应该使用try-with结构来确保在流式操作完成后,数据流的close方法被调用。
下面的例子演示了如何查找在目录及其子目录下的文件:
- Path start = Paths.get("");
- int maxDepth = 5;
- try (Stream<Path> stream = Files.find(start, maxDepth, (path, attr) ->
- String.valueOf(path).endsWith(".js"))) {
- String joined = stream
- .sorted()
- .map(String::valueOf)
- .collect(Collectors.joining("; "));
- System.out.println("Found: " + joined);
- }
find方法接受三个参数: 目录路径start是起始点,maxDepth定义了最大搜索深度。第三个参数是一个匹配谓词,定义了搜索的逻辑。上面的例子中,我们搜索了所有JavaScirpt文件(以.js结尾的文件名)。
我们可以使用Files.walk方法来完成相同的行为。这个方法会遍历每个文件,而不需要传递搜索谓词。
- Path start = Paths.get("");
- int maxDepth = 5;
- try (Stream<Path> stream = Files.walk(start, maxDepth)) {
- String joined = stream
- .map(String::valueOf)
- .filter(path -> path.endsWith(".js"))
- .sorted()
- .collect(Collectors.joining("; "));
- System.out.println("walk(): " + joined);
- }
这个例子中,我们使用了流式操作filter来完成和上个例子相同的行为。
将文本文件读到内存,以及向文本文件写入字符串在Java 8 中是简单的任务。不需要再去摆弄读写器了。Files.readAllLines从指定的文件把所有行读进字符串列表中。你可以简单地修改这个列表,并且将它通过Files.write写到另一个文件中:
- List<String> lines = Files.readAllLines(Paths.get("res/nashorn1.js"));
- lines.add("print('foobar');");
- Files.write(Paths.get("res/nashorn1-modified.js"), lines);
要注意这些方法对内存并不十分高效,因为整个文件都会读进内存。文件越大,所用的堆区也就越大。
你可以使用Files.lines方法来作为内存高效的替代。这个方法读取每一行,并使用函数式数据流来对其流式处理,而不是一次性把所有行都读进内存。
- try (Stream<String> stream = Files.lines(Paths.get("res/nashorn1.js"))) {
- stream
- .filter(line -> line.contains("print"))
- .map(String::trim)
- .forEach(System.out::println);
- }
如果你需要更多的精细控制,你需要构造一个新的BufferedReader来代替:
- Path path = Paths.get("res/nashorn1.js");
- try (BufferedReader reader = Files.newBufferedReader(path)) {
- System.out.println(reader.readLine());
- }
或者,你需要写入文件时,简单地构造一个BufferedWriter来代替:
- Path path = Paths.get("res/output.js");
- try (BufferedWriter writer = Files.newBufferedWriter(path)) {
- writer.write("print('Hello World');");
- }
BufferedReader也可以访问函数式数据流。lines方法在它所有行上面构建数据流:
- Path path = Paths.get("res/nashorn1.js");
- try (BufferedReader reader = Files.newBufferedReader(path)) {
- long countPrints = reader
- .lines()
- .filter(line -> line.contains("print"))
- .count();
- System.out.println(countPrints);
- }
目前为止你可以看到Java8提供了三个简单的方法来读取文本文件的每一行,使文件处理更加便捷。
不幸的是你需要显式使用try-with语句来关闭文件流,这会使示例代码有些凌乱。我期待函数式数据流可以在调用类似count和collect时可以自动关闭,因为你不能在相同数据流上调用终止操作两次。
在Java8中java.util.Random类的一个非常明显的变化就是新增了返回随机数流(random Stream of numbers)的一些方法。
下面的代码是创建一个无穷尽的double类型的数字流,这些数字在0(包括0)和1(不包含1)之间。
- Random random = new Random();
- DoubleStream doubleStream = random.doubles();
下面的代码是创建一个无穷尽的int类型的数字流,这些数字在0(包括0)和100(不包括100)之间。
- Random random = new Random();
- IntStream intStream = random.ints(0, 100);
那么这些无穷尽的数字流用来做什么呢? 接下来,我通过一些案例来分析。记住,这些无穷大的数字流只能通过某种方式被截断(limited)。
示例1: 创建10个随机的整数流并打印出来:
intStream.limit(10).forEach(System.out::println);
示例2: 创建100个随机整数:
- List<Integer> randomBetween0And99 = intStream
- .limit(100)
- .boxed()
- .collect(Collectors.toList());
对于高斯伪随机数(gaussian pseudo-random values)来说,random.doubles()方法所创建的流不能等价于高斯伪随机数,然而,如果用java8所提供的功能是非常容易实现的。
- Random random = new Random();
- DoubleStream gaussianStream = Stream.generate(random::nextGaussian).mapToDouble(e -> e);
这里,我使用了Stream.generate api,并传入Supplier 类的对象作为参数,这个对象是通过调用Random类中的方法 nextGaussian()创建另一个高斯伪随机数。
接下来,我们来对double类型的伪随机数流和double类型的高斯伪随机数流做一个更加有意思的事情,那就是获得两个流的随机数的分配情况。预期的结果是: double类型的伪随机数是均匀的分配的,而double类型的高斯伪随机数应该是正态分布的。
通过下面的代码,我生成了一百万个伪随机数,这是通过java8提供的api实现的:
- Random random = new Random();
- DoubleStream doubleStream = random.doubles(-1.0, 1.0);
- LinkedHashMap<Range, Integer> rangeCountMap = doubleStream.limit(1000000)
- .boxed()
- .map(Ranges::of)
- .collect(Ranges::emptyRangeCountMap, (m, e) -> m.put(e, m.get(e) + 1), Ranges::mergeRangeCountMaps);
-
- rangeCountMap.forEach((k, v) -> System.out.println(k.from() + "\t" + v));
代码的运行结果如下:
- -1 49730
- -0.9 49931
- -0.8 50057
- -0.7 50060
- -0.6 49963
- -0.5 50159
- -0.4 49921
- -0.3 49962
- -0.2 50231
- -0.1 49658
- 0 50177
- 0.1 49861
- 0.2 49947
- 0.3 50157
- 0.4 50414
- 0.5 50006
- 0.6 50038
- 0.7 49962
- 0.8 50071
- 0.9 49695
为了类比,我们再生成一百万个高斯伪随机数:
- Random random = new Random();
- DoubleStream gaussianStream = Stream.generate(random::nextGaussian).mapToDouble(e -> e);
- LinkedHashMap<Range, Integer> gaussianRangeCountMap =
- gaussianStream
- .filter(e -> (e >= -1.0 && e < 1.0))
- .limit(1000000)
- .boxed()
- .map(Ranges::of)
- .collect(Ranges::emptyRangeCountMap, (m, e) -> m.put(e, m.get(e) + 1), Ranges::mergeRangeCountMaps);
-
- gaussianRangeCountMap.forEach((k, v) -> System.out.println(k.from() + "\t" + v));
上面代码输出的结果恰恰与我们预期结果相吻合,即: double类型的伪随机数是均匀的分配的,而double类型的高斯伪随机数应该是正态分布的。
附: 完整代码可点击这里获取 https://gist.github.com/bijukunjummen/8129250
译文链接: http://www.importnew.com/9672.html
Java8中java.util.Base64性能比较高,推荐使用。请参考:
性能对比: https://wizardforcel.gitbooks.io/java8-new-features/content/11.html
源代码: http://git.oschina.net/benhail/javase8-sample
该类提供了一套静态方法获取下面三种BASE64编解码器:
1)Basic编码: 是标准的BASE64编码,用于处理常规的需求
- // 编码
- String asB64 = Base64.getEncoder().encodeToString("some string".getBytes("utf-8"));
- System.out.println(asB64); // 输出为: c29tZSBzdHJpbmc=
- // 解码
- byte[] asBytes = Base64.getDecoder().decode("c29tZSBzdHJpbmc=");
- System.out.println(new String(asBytes, "utf-8")); // 输出为: some string
2)URL编码: 使用下划线替换URL里面的反斜线“/”
- String urlEncoded = Base64.getUrlEncoder().encodeToString("subjects?abcd".getBytes("utf-8"));
- System.out.println("Using URL Alphabet: " + urlEncoded);
- // 输出为:
- Using URL Alphabet: c3ViamVjdHM_YWJjZA==
3)MIME编码: 使用基本的字母数字产生BASE64输出,而且对MIME格式友好: 每一行输出不超过76个字符,而且每行以“\r\n”符结束。
- StringBuilder sb = new StringBuilder();
- for (int t = 0; t < 10; ++t) {
- sb.append(UUID.randomUUID().toString());
- }
- byte[] toEncode = sb.toString().getBytes("utf-8");
- String mimeEncoded = Base64.getMimeEncoder().encodeToString(toEncode);
- System.out.println(mimeEncoded);
来源:pdai.tech/md/java/java8/java8.html
Java 平台模块系统,也就是 Project Jigsaw,把模块化开发实践引入到了 Java 平台中。在引入了模块系统之后,JDK 被重新组织成 94 个模块。Java 应用可以通过新增的 jlink 工具,创建出只包含所依赖的 JDK 模块的自定义运行时镜像。这样可以极大的减少 Java 运行时环境的大小。这对于目前流行的不可变基础设施的实践来说,镜像的大小的减少可以节省很多存储空间和带宽资源 。
模块化开发的实践在软件开发领域并不是一个新的概念。Java 开发社区已经使用这样的模块化实践有相当长的一段时间。主流的构建工具,包括 Apache Maven 和 Gradle 都支持把一个大的项目划分成若干个子项目。子项目之间通过不同的依赖关系组织在一起。每个子项目在构建之后都会产生对应的 JAR 文件。在 Java9 中 ,已有的这些项目可以很容易的升级转换为 Java 9 模块 ,并保持原有的组织结构不变。
Java 9 模块的重要特征是在其工件(artifact)的根目录中包含了一个描述模块的 module-info.class 文 件。工件的格式可以是传统的 JAR 文件或是 Java 9 新增的 JMOD 文件。这个文件由根目录中的源代码文件 module-info.java 编译而来。该模块声明文件可以描述模块的不同特征。模块声明文件中可以包含的内容如下:
模块导出的包:使用 exports 可以声明模块对其他模块所导出的包。包中的 public 和 protected 类型,以及这些类型的 public 和 protected 成员可以被其他模块所访问。没有声明为导出的包相当于模块中的私有成员,不能被其他模块使用。
模块的依赖关系:使用 requires 可以声明模块对其他模块的依赖关系。使用 requires transitive 可 以把一个模块依赖声明为传递的。传递的模块依赖可以被依赖当前模块的其他模块所读取。如果一个模块所导出的类型的型构中包含了来自它所依赖的模块的类型,那么对该模块的依赖应该声明为传递的。
服务的提供和使用:如果一个模块中包含了可以被 ServiceLocator 发现的服务接口的实现 ,需要使用 provides with 语句来声明具体的实现类 ;如果一个模块需要使用服务接口,可以使用 uses 语句来声明。
如下代码中给出了一个模块声明文件的示例。在该声明文件中,模块 com.mycompany.sample
导出了 Java 包 com.mycompany.sample
。该模块依赖于模块 com.mycompany.common
。该模块也提供了服务接口 com.mycompany.common.DemoService
的实现类 com.mycompany.sample.DemoServiceImpl
。
- module com.mycompany.sample {
- exports com.mycompany.sample;
- requires com.mycompany.common;
- provides com.mycompany.common.DemoService with
- com.mycompany.sample.DemoServiceImpl;
- }
模块系统中增加了模块路径的概念。模块系统在解析模块时,会从模块路径中进行查找。为了保持与之前 Java 版本的兼容性,CLASSPATH 依然被保留。所有的类型在运行时都属于某个特定的模块。对于从 CLASSPATH 中加载的类型,它们属于加载它们的类加载器对应的未命名模块。可以通过 Class 的 getModule()方法来获取到表示其所在模块的 Module 对象。
在 JVM 启动时,会从应用的根模块开始,根据依赖关系递归的进行解析,直到得到一个表示依赖关系的图。如果解析过程中出现找不到模块的情况,或是在模块路径的同一个地方找到了名称相同的模块,模块解析过程会终止,JVM 也会退出。Java 也提供了相应的 API 与模块系统进行交互。
jshell 是 Java 9 新增的一个实用工具。jshell 为 Java 增加了类似 NodeJS 和 Python 中的读取-求值-打印循环( Read-Evaluation-Print Loop ) 。在 jshell 中 可以直接 输入表达式并查看其执行结果。当需要测试一个方法的运行效果,或是快速的对表达式进行求值时,jshell 都非常实用。只需要通过 jshell 命令启动 jshell,然后直接输入表达式即可。每个表达式的结果会被自动保存下来 ,以数字编号作为引用,类似 2 这样的名称 。可以在后续的表达式中引用之前语句的运行结果。在 jshell 中 ,除了表达式之外,还可以创建 Java 类和方法。jshell 也有基本的代码完成功能。
在 如下代码 中,我们直接创建了一个方法 add。
- jshell> int add(int x, int y) {
- ...> return x + y;
- ...> }
- | created method add(int,int)
接着就可以在 jshell 中直接使用这个方法,如下代码 所示。
- jshell> add(1, 2)
- $19 ==> 3
在集合上,Java 9 增加 了 List.of()
、Set.of()
、Map.of()
和 Map.ofEntries()
等工厂方法来创建不可变集合 ,如 如下 所示。
- List.of();
- List.of("Hello", "World");
- List.of(1, 2, 3);
- Set.of();
- Set.of("Hello", "World");
- Set.of(1, 2, 3);
- Map.of();
- Map.of("Hello", 1, "World", 2);
Stream 中增加了新的方法 ofNullable、dropWhile、takeWhile 和 iterate。在 如下代码 中,流中包含了从 1 到 5 的 元素。断言检查元素是否为奇数。第一个元素 1 被删除,结果流中包含 4 个元素。
- @Test
- public void testDropWhile() throws Exception {
- final long count = Stream.of(1, 2, 3, 4, 5)
- .dropWhile(i -> i % 2 != 0)
- .count();
- assertEquals(4, count);
- }
Collectors 中增加了新的方法 filtering 和 flatMapping。在 如下代码 中,对于输入的 String 流 ,先通过 flatMapping 把 String 映射成 Integer 流 ,再把所有的 Integer 收集到一个集合中。
- @Test
- public void testFlatMapping() throws Exception {
- final Set<Integer> result = Stream.of("a", "ab", "abc")
- .collect(Collectors.flatMapping(v -> v.chars().boxed(),
- Collectors.toSet()));
- assertEquals(3, result.size());
- }
Optional 类中新增了 ifPresentOrElse、or 和 stream 等方法。在 如下代码 中,Optiona l 流中包含 3 个 元素,其中只有 2 个有值。在使用 flatMap 之后,结果流中包含了 2 个值。
- @Test
- public void testStream() throws Exception {
- final long count = Stream.of(
- Optional.of(1),
- Optional.empty(),
- Optional.of(2)
- ).flatMap(Optional::stream)
- .count();
- assertEquals(2, count);
- }
Java 9 增加了 ProcessHandle 接口,可以对原生进程进行管理,尤其适合于管理长时间运行的进程。在使用 ProcessBuilder 来启动一个进程之后,可以通过 Process.toHandle()方法来得到一个 ProcessHandl e 对象的实例。通过 ProcessHandle 可以获取到由 ProcessHandle.Info 表 示的进程的基本信息,如命令行参数、可执行文件路径和启动时间等。ProcessHandle 的 onExit()方法返回一个 CompletableFuture对象,可以在进程结束时执行自定义的动作。如下代码中给出了进程 API 的使用示例。
- final ProcessBuilder processBuilder = new ProcessBuilder("top")
- .inheritIO();
- final ProcessHandle processHandle = processBuilder.start().toHandle();
- processHandle.onExit().whenCompleteAsync((handle, throwable) -> {
- if (throwable == null) {
- System.out.println(handle.pid());
- } else {
- throwable.printStackTrace();
- }
- });
Java 9 允许为 JDK 和应用配置同样的日志实现。新增的 System.LoggerFinder 用来管理 JDK 使 用的日志记录器实现。JVM 在运行时只有一个系统范围的 LoggerFinder 实例。LoggerFinder 通 过服务查找机制来加载日志记录器实现。默认情况下,JDK 使用 java.logging 模块中的 java.util.logging 实现。通过 LoggerFinder 的 getLogger()方法就可以获取到表示日志记录器的 System.Logger 实现。应用同样可以使用 System.Logger 来记录日志。这样就保证了 JDK 和应用使用同样的日志实现。我们也可以通过添加自己的 System.LoggerFinder 实现来让 JDK 和应用使用 SLF4J 等其他日志记录框架。代码清单 9 中给出了平台日志 API 的使用示例。
- public class Main {
- private static final System.Logger LOGGER = System.getLogger("Main");
- public static void main(final String[] args) {
- LOGGER.log(Level.INFO, "Run!");
- }
- }
反应式编程的思想最近得到了广泛的流行。在 Java 平台上有流行的反应式 库 RxJava 和 R eactor。反应式流规范的出发点是提供一个带非阻塞负压( non-blocking backpressure ) 的异步流处理规范。反应式流规范的核心接口已经添加到了 Java9 中的 java.util.concurrent.Flow 类中。
Flow 中包含了 Flow.Publisher、Flow.Subscriber、Flow.Subscription 和 F low.Processor 等 4 个核心接口。Java 9 还提供了 SubmissionPublisher 作为 Flow.Publisher 的一个实现。RxJava 2 和 Reactor 都可以很方便的 与 Flow 类的核心接口进行互操作。
变量句柄是一个变量或一组变量的引用,包括静态域,非静态域,数组元素和堆外数据结构中的组成部分等。变量句柄的含义类似于已有的方法句柄。变量句柄由 J ava 类 java.lang.invoke.VarHandle 来表示。可以使用类 j ava.lang.invoke.MethodHandles.Looku p 中的静态工厂方法来创建 VarHandle 对 象。通过变量句柄,可以在变量上进行各种操作。这些操作称为访问模式。不同的访问模式尤其在内存排序上的不同语义。目前一共有 31 种 访问模式,而每种访问模式都 在 VarHandle 中 有对应的方法。这些方法可以对变量进行读取、写入、原子更新、数值原子更新和比特位原子操作等。VarHandle 还 可以用来访问数组中的单个元素,以及把 byte[]数组 和 ByteBuffer 当成是不同原始类型的数组来访问。
在 如下代码 中,我们创建了访问 HandleTarget 类中的域 count 的变量句柄,并在其上进行读取操作。
- public class HandleTarget {
- public int count = 1;
- }
- public class VarHandleTest {
- private HandleTarget handleTarget = new HandleTarget();
- private VarHandle varHandle;
- @Before
- public void setUp() throws Exception {
- this.handleTarget = new HandleTarget();
- this.varHandle = MethodHandles
- .lookup()
- .findVarHandle(HandleTarget.class, "count", int.class);
- }
- @Test
- public void testGet() throws Exception {
- assertEquals(1, this.varHandle.get(this.handleTarget));
- assertEquals(1, this.varHandle.getVolatile(this.handleTarget));
- assertEquals(1, this.varHandle.getOpaque(this.handleTarget));
- assertEquals(1, this.varHandle.getAcquire(this.handleTarget));
- }
- }
类 java.lang.invoke.MethodHandles 增加了更多的静态方法来创建不同类型的方法句柄。
arrayConstructor:创建指定类型的数组。
arrayLength:获取指定类型的数组的大小。
varHandleInvoker 和 varHandleExactInvoker:调用 VarHandle 中的访问模式方法。
zero:返回一个类型的默认值。
empty:返 回 MethodType 的返回值类型的默认值。
loop、countedLoop、iteratedLoop、whileLoop 和 doWhileLoop:创建不同类型的循环,包括 for 循环、while 循环 和 do-while 循环。
tryFinally:把对方法句柄的调用封装在 try-finally 语句中。
在 如下代码 中,我们使用 iteratedLoop 来创建一个遍历 S tring 类型迭代器的方法句柄,并计算所有字符串的长度的总和。
- public class IteratedLoopTest {
- static int body(final int sum, final String value) {
- return sum + value.length();
- }
- @Test
- public void testIteratedLoop() throws Throwable {
- final MethodHandle iterator = MethodHandles.constant(
- Iterator.class,
- List.of("a", "bc", "def").iterator());
- final MethodHandle init = MethodHandles.zero(int.class);
- final MethodHandle body = MethodHandles
- .lookup()
- .findStatic(
- IteratedLoopTest.class,
- "body",
- MethodType.methodType(
- int.class,
- int.class,
- String.class));
- final MethodHandle iteratedLoop = MethodHandles
- .iteratedLoop(iterator, init, body);
- assertEquals(6, iteratedLoop.invoke());
- }
- }
在并发方面,类 CompletableFuture 中增加了几个新的方法。completeAsync 使用一个异步任务来获取结果并完成该 CompletableFuture。orTimeout 在 CompletableFuture 没有在给定的超时时间之前完成,使用 TimeoutException 异常来完成 CompletableFuture。completeOnTimeout 与 o rTimeout 类似,只不过它在超时时使用给定的值来完成 CompletableFuture。新的 Thread.onSpinWai t 方法在当前线程需要使用忙循环来等待时,可以提高等待的效率。
Nashorn 是 Java 8 中引入的新的 JavaScript 引擎。Java 9 中的 Nashorn 已经实现了一些 ECMAScript 6 规范中的新特性,包括模板字符串、二进制和八进制字面量、迭代器 和 for..of 循环和箭头函数等。Nashorn 还提供了 API 把 ECMAScript 源代码解析成抽象语法树( Abstract Syntax Tree,AST ) ,可以用来对 ECMAScript 源代码进行分析。
类 java.io.InputStream 中增加了新的方法来读取和复制 InputStream 中包含的数据。
readAllBytes:读取 InputStream 中的所有剩余字节。
readNBytes:从 InputStream 中读取指定数量的字节到数组中。
transferTo:读取 InputStream 中的全部字节并写入到指定的 OutputStream 中 。
- public class TestInputStream {
- private InputStream inputStream;
- private static final String CONTENT = "Hello World";
- @Before
- public void setUp() throws Exception {
- this.inputStream =
- TestInputStream.class.getResourceAsStream("/input.txt");
- }
- @Test
- public void testReadAllBytes() throws Exception {
- final String content = new String(this.inputStream.readAllBytes());
- assertEquals(CONTENT, content);
- }
- @Test
- public void testReadNBytes() throws Exception {
- final byte[] data = new byte[5];
- this.inputStream.readNBytes(data, 0, 5);
- assertEquals("Hello", new String(data));
- }
- @Test
- public void testTransferTo() throws Exception {
- final ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
- this.inputStream.transferTo(outputStream);
- assertEquals(CONTENT, outputStream.toString());
- }
- }
ObjectInputFilter 可以对 ObjectInputStream 中 包含的内容进行检查,来确保其中包含的数据是合法的。可以使用 ObjectInputStream 的方法 setObjectInputFilter 来设置。ObjectInputFilter 在 进行检查时,可以检查如对象图的最大深度、对象引用的最大数量、输入流中的最大字节数和数组的最大长度等限制,也可以对包含的类的名称进行限制。
Java 9 新增了 4 个 SHA- 3 哈希算法,SHA3-224、SHA3-256、SHA3-384 和 S HA3-512。另外也增加了通过 java.security.SecureRandom 生成使用 DRBG 算法的强随机数。如下代码中给出了 SHA-3 哈希算法的使用示例。
- import org.apache.commons.codec.binary.Hex;
- public class SHA3 {
- public static void main(final String[] args) throws NoSuchAlgorithmException {
- final MessageDigest instance = MessageDigest.getInstance("SHA3-224");
- final byte[] digest = instance.digest("".getBytes());
- System.out.println(Hex.encodeHexString(digest));
- }
- }
类 java.awt.Desktop 增加了新的与桌面进行互动的能力。可以使用 addAppEventListener 方法来添加不同应用事件的监听器,包括应用变为前台应用、应用隐藏或显示、屏幕和系统进入休眠与唤醒、以及 用户会话的开始和终止等。还可以在显示关于窗口和配置窗口时,添加自定义的逻辑。在用户要求退出应用时,可以通过自定义处理器来接受或拒绝退出请求。在 A WT 图像支持方面,可以在应用中使用多分辨率图像。
Java 9 中 ,JVM 有了统一的日志记录系统,可以使用新的命令行选项-Xlog 来控制 JVM 上 所有组件的日志记录。该日志记录系统可以设置输出的日志消息的标签、级别、修饰符和输出目标等。Java 9 移除了在 Java 8 中 被废弃的垃圾回收器配置组合,同时 把 G1 设为默认的垃圾回收器实现。另外,CMS 垃圾回收器已经被声明为废弃。Java 9 也增加了很多可以通过 jcmd 调用的诊断命令。
在 Java 语言本身,Java 9 允许在接口中使用私有方法。在 try-with-resources 语句中可以使用 effectively-final 变量。类 java.lang.StackWalker 可 以对线程的堆栈进行遍历,并且支持过滤和延迟访问。Java 9 把对 Unicode 的支持升级到了 8.0。ResourceBundle 加载属性文件的默认编码从 ISO-8859-1 改成了 UTF-8,不再需要使用 native2ascii 命 令来对属性文件进行额外处理。注解@Deprecated 也得到了增强,增加了 since 和 forRemoval 两 个属性,可以分别指定一个程序元素被废弃的版本,以及是否会在今后的版本中被删除。
在如下代码中,buildMessage 是接口 SayHi 中的私有方法,在默认方法 sayHi 中被使用。
- public interface SayHi {
- private String buildMessage() {
- return "Hello";
- }
- void sayHi(final String message);
- default void sayHi() {
- sayHi(buildMessage());
- }
- }
作为 Java 平台最新的一个重大更新,Java 9 中的很多新特性,尤其模块系统,对于 Java 应用的开发会产生深远的影响。本文对 Java 9 中的新特性做了概括的介绍,可以作为了解 Java 9 的基础。这些新特性的相信内容,可以通过官方文档来进一步的了解。
本文转载自https://developer.ibm.com/zh/articles/the-new-features-of-Java-9/
局部变量类型推断是 Java 10 中最值得开发人员注意的新特性,这是 Java 语言开发人员为了简化 Java 应用程序的编写而进行的又一重要改进。
这一新功能将为 Java 增加一些新语法,允许开发人员省略通常不必要的局部变量类型初始化声明。新的语法将减少 Java 代码的冗长度,同时保持对静态类型安全性的承诺。局部变量类型推断主要是向 Java 语法中引入在其他语言(比如 C#、JavaScript)中很常见的保留类型名称 var 。但需要特别注意的是:var 不是一个关键字,而是一个保留字。只要编译器可以推断此种类型,开发人员不再需要专门声明一个局部变量的类型,也就是可以随意定义变量而不必指定变量的类型。这种改进对于链式表达式来说,也会很方便。以下是一个简单的例子:
清单 1. 局部变量类型推断示例
- var list = new ArrayList<String>(); // ArrayList<String>
- var stream = list.stream(); // Stream<String>
看着是不是有点 JS 的感觉?有没有感觉越来越像 JS 了?虽然变量类型的推断在 Java 中不是一个崭新的概念,但在局部变量中确是很大的一个改进。说到变量类型推断,从 Java 5 中引进泛型,到 Java 7 的 <>
操作符允许不绑定类型而初始化 List,再到 Java 8 中的 Lambda 表达式,再到现在 Java 10 中引入的局部变量类型推断,Java 类型推断正大刀阔斧地向前进步、发展。
而上面这段例子,在以前版本的 Java 语法中初始化列表的写法为:
清单 2. Java 类型初始化示例
- List<String> list = new ArrayList<String>();
- Stream<String> stream = getStream();
在运算符允许在没有绑定 ArrayList <>
的类型的情况下初始化列表的写法为:
清单 3. Java 7 之后版本类型初始化示例
- List<String> list = new LinkedList<>();
- Stream<String> stream = getStream();
但这种 var 变量类型推断的使用也有局限性,仅局限于具有初始化器的局部变量、增强型 for 循环中的索引变量以及在传统 for 循环中声明的局部变量,而不能用于推断方法的参数类型,不能用于构造函数参数类型推断,不能用于推断方法返回类型,也不能用于字段类型推断,同时还不能用于捕获表达式(或任何其他类型的变量声明)。
不过对于开发者而言,变量类型显式声明会提供更加全面的程序语言信息,对于理解和维护代码有很大的帮助。Java 10 中新引入的局部变量类型推断能够帮助我们快速编写更加简洁的代码,但是局部变量类型推断的保留字 var 的使用势必会引起变量类型可视化缺失,并不是任何时候使用 var 都能容易、清晰的分辨出变量的类型。一旦 var 被广泛运用,开发者在没有 IDE 的支持下阅读代码,势必会对理解程序的执行流程带来一定的困难。所以还是建议尽量显式定义变量类型,在保持代码简洁的同时,也需要兼顾程序的易读性、可维护性。
为了简化开发流程,Java 10 中会将多个代码库合并到一个代码仓库中。
在已发布的 Java 版本中,JDK 的整套代码根据不同功能已被分别存储在多个 Mercurial 存储库,这八个 Mercurial 存储库分别是:root、corba、hotspot、jaxp、jaxws、jdk、langtools、nashorn。
虽然以上八个存储库之间相互独立以保持各组件代码清晰分离,但同时管理这些存储库存在许多缺点,并且无法进行相关联源代码的管理操作。其中最重要的一点是,涉及多个存储库的变更集无法进行原子提交 (atomic commit)。例如,如果一个 bug 修复时需要对独立存储两个不同代码库的代码进行更改,那么必须创建两个提交:每个存储库中各一个。这种不连续性很容易降低项目和源代码管理工具的可跟踪性和加大复杂性。特别是,不可能跨越相互依赖的变更集的存储库执行原子提交这种多次跨仓库的变化是常见现象。
为了解决这个问题,JDK 10 中将所有现有存储库合并到一个 Mercurial 存储库中。这种合并的一个次生效应是,单一的 Mercurial 存储库比现有的八个存储库要更容易地被镜像(作为一个 Git 存储库),并且使得跨越相互依赖的变更集的存储库运行原子提交成为可能,从而简化开发和管理过程。虽然在整合过程中,外部开发人员有一些阻力,但是 JDK 开发团队已经使这一更改成为 JDK 10 的一部分。
在当前的 Java 结构中,组成垃圾回收器(GC)实现的组件分散在代码库的各个部分。尽管这些惯例对于使用 GC 计划的 JDK 开发者来说比较熟悉,但对新的开发人员来说,对于在哪里查找特定 GC 的源代码,或者实现一个新的垃圾收集器常常会感到困惑。更重要的是,随着 Java modules 的出现,我们希望在构建过程中排除不需要的 GC,但是当前 GC 接口的横向结构会给排除、定位问题带来困难。
为解决此问题,需要整合并清理 GC 接口,以便更容易地实现新的 GC,并更好地维护现有的 GC。Java 10 中,hotspot/gc 代码实现方面,引入一个干净的 GC 接口,改进不同 GC 源代码的隔离性,多个 GC 之间共享的实现细节代码应该存在于辅助类中。这种方式提供了足够的灵活性来实现全新 GC 接口,同时允许以混合搭配方式重复使用现有代码,并且能够保持代码更加干净、整洁,便于排查收集器问题。
大家如果接触过 Java 性能调优工作,应该会知道,调优的最终目标是通过参数设置来达到快速、低延时的内存垃圾回收以提高应用吞吐量,尽可能的避免因内存回收不及时而触发的完整 GC(Full GC 会带来应用出现卡顿)。
G1 垃圾回收器是 Java 9 中 Hotspot 的默认垃圾回收器,是以一种低延时的垃圾回收器来设计的,旨在避免进行 Full GC,但是当并发收集无法快速回收内存时,会触发垃圾回收器回退进行 Full GC。之前 Java 版本中的 G1 垃圾回收器执行 GC 时采用的是基于单线程标记扫描压缩算法(mark-sweep-compact)。为了最大限度地减少 Full GC 造成的应用停顿的影响,Java 10 中将为 G1 引入多线程并行 GC,同时会使用与年轻代回收和混合回收相同的并行工作线程数量,从而减少了 Full GC 的发生,以带来更好的性能提升、更大的吞吐量。
Java 10 中将采用并行化 mark-sweep-compact 算法,并使用与年轻代回收和混合回收相同数量的线程。具体并行 GC 线程数量可以通过:-XX:ParallelGCThreads
参数来调节,但这也会影响用于年轻代和混合收集的工作线程数。
在 Java 5 中就已经引入了类数据共享机制 (Class Data Sharing,简称 CDS),允许将一组类预处理为共享归档文件,以便在运行时能够进行内存映射以减少 Java 程序的启动时间,当多个 Java 虚拟机(JVM)共享相同的归档文件时,还可以减少动态内存的占用量,同时减少多个虚拟机在同一个物理或虚拟的机器上运行时的资源占用。简单来说,Java 安装程序会把 rt.jar 中的核心类提前转化成内部表示,转储到一个共享存档(shared archive)中。多个 Java 进程(或者说 JVM 实例)可以共享这部分数据。为改善启动和占用空间,Java 10 在现有的 CDS 功能基础上再次拓展,以允许应用类放置在共享存档中。
CDS 特性在原来的 bootstrap 类基础之上,扩展加入了应用类的 CDS (Application Class-Data Sharing) 支持。
其原理为:在启动时记录加载类的过程,写入到文本文件中,再次启动时直接读取此启动文本并加载。设想如果应用环境没有大的变化,启动速度就会得到提升。
可以想像为类似于操作系统的休眠过程,合上电脑时把当前应用环境写入磁盘,再次使用时就可以快速恢复环境。
对大型企业应用程序的内存使用情况的分析表明,此类应用程序通常会将数以万计的类加载到应用程序类加载器中,如果能够将 AppCDS 应用于这些应用,将为每个 JVM 进程节省数十乃至数百兆字节的内存。另外对于云平台上的微服务分析表明,许多服务器在启动时会加载数千个应用程序类,AppCDS 可以让这些服务快速启动并改善整个系统响应时间。
在已有的 Java 版本中,JVM 线程只能全部启用或者停止,没法做到对单独某个线程的操作。为了能够对单独的某个线程进行操作,Java 10 中线程管控引入 JVM 安全点的概念,将允许在不运行全局 JVM 安全点的情况下实现线程回调,由线程本身或者 JVM 线程来执行,同时保持线程处于阻塞状态,这种方式使得停止单个线程变成可能,而不是只能启用或停止所有线程。通过这种方式显著地提高了现有 JVM 功能的性能开销,并且改变了到达 JVM 全局安全点的现有时间语义。
增加的参数为:-XX:ThreadLocalHandshakes
(默认为开启),将允许用户在支持的平台上选择安全点。
自 Java 9 以来便开始了一些对 JDK 的调整,用户每次调用 javah 工具时会被警告该工具在未来的版本中将会执行的删除操作。当编译 JNI 代码时,已不再需要单独的 Native-Header 工具来生成头文件,因为这可以通过 Java 8(JDK-7150368)中添加的 javac 来完成。在未来的某一时刻,JNI 将会被 Panama 项目的结果取代,但是何时发生还没有具体时间表。
自 Java 7 开始支持 BCP 47 语言标记以来, JDK 中便增加了与日历和数字相关的 Unicode 区域设置扩展,在 Java 9 中,新增支持 ca 和 nu 两种语言标签扩展。而在 Java 10 中将继续增加 Unicode 语言标签扩展,具体为:增强 java.util.Locale 类及其相关的 API,以更方便的获得所需要的语言地域环境信息。同时在这次升级中还带来了如下扩展支持:
表 1.Unicode 扩展表
如 Java 10 加入的一个方法:
清单 4. Unicode 语言标签扩展示例
java.time.format.DateTimeFormatter::localizedBy
通过这个方法,可以采用某种数字样式,区域定义或者时区来获得时间信息所需的语言地域本地环境信息。
硬件技术在持续进化,现在可以使用与传统 DRAM 具有相同接口和类似性能特点的非易失性 RAM。Java 10 中将使得 JVM 能够使用适用于不同类型的存储机制的堆,在可选内存设备上进行堆内存分配。
一些操作系统中已经通过文件系统提供了使用非 DRAM 内存的方法。例如:NTFS DAX 模式和 ext4 DAX。这些文件系统中的内存映射文件可绕过页面缓存并提供虚拟内存与设备物理内存的相互映射。与 DRAM 相比,NV-DIMM 可能具有更高的访问延迟,低优先级进程可以为堆使用 NV-DIMM 内存,允许高优先级进程使用更多 DRAM。
要在这样的备用设备上进行堆分配,可以使用堆分配参数 -XX:AllocateHeapAt = <path>
,这个参数将指向文件系统的文件并使用内存映射来达到在备用存储设备上进行堆分配的预期结果。
Java 10 中开启了基于 Java 的 JIT 编译器 Graal,并将其用作 Linux/x64 平台上的实验性 JIT 编译器开始进行测试和调试工作,另外 Graal 将使用 Java 9 中引入的 JVM 编译器接口(JVMCI)。
Graal 是一个以 Java 为主要编程语言、面向 Java bytecode 的编译器。与用 C++实现的 C1 及 C2 相比,它的模块化更加明显,也更加容易维护。Graal 既可以作为动态编译器,在运行时编译热点方法;亦可以作为静态编译器,实现 AOT 编译。在 Java 10 中,Graal 作为试验性 JIT 编译器一同发布(JEP 317)。将 Graal 编译器研究项目引入到 Java 中,或许能够为 JVM 性能与当前 C++ 所写版本匹敌(或有幸超越)提供基础。
Java 10 中默认情况下 HotSpot 仍使用的是 C2 编译器,要启用 Graal 作为 JIT 编译器,请在 Java 命令行上使用以下参数:
清单 5. 启用 Graal 为 JIT 编译器示例
-XX:+ UnlockExperimentalVMOptions -XX:+ UseJVMCICompiler
自 Java 9 起在 keytool 中加入参数 -cacerts ,可以查看当前 JDK 管理的根证书。而 Java 9 中 cacerts 目录为空,这样就会给开发者带来很多不便。从 Java 10 开始,将会在 JDK 中提供一套默认的 CA 根证书。
作为 JDK 一部分的 cacerts 密钥库旨在包含一组能够用于在各种安全协议的证书链中建立信任的根证书。但是,JDK 源代码中的 cacerts 密钥库至目前为止一直是空的。因此,在 JDK 构建中,默认情况下,关键安全组件(如 TLS)是不起作用的。要解决此问题,用户必须使用一组根证书配置和 cacerts 密钥库下的 CA 根证书。
虽然 JEP 223 中引入的版本字符串方案较以往有了显著的改进。但是,该方案并不适合以后严格按照六个月的节奏来发布 Java 新版本的这种情况。
按照 JEP 223 的语义中,每个基于 JDK 构建或使用组件的开发者(包括 JDK 的发布者)都必须提前敲定版本号,然后切换过去。开发人员则必须在代码中修改检查版本号的相关代码,这对所有参与者来说都很尴尬和混乱。
Java 10 中将重新编写之前 JDK 版本中引入的版本号方案,将使用基于时间模型定义的版本号格式来定义新版本。保留与 JEP 223 版本字符串方案的兼容性,同时也允许除当前模型以外的基于时间的发布模型。使开发人员或终端用户能够轻松找出版本的发布时间,以便开发人员能够判断是否将其升级到具有最新安全修补程序或可能的附加功能的新版本。
Oracle Java 平台组的首席架构师 Mark Reinhold 在博客上介绍了有关 Java 未来版本的一些想法(你能接受 Java 9 的下一个版本是 Java 18.3 吗?)。他提到,Java 计划按照时间来发布,每半年一个版本,而不是像之前那样按照重要特性来确定大版本,如果某个大的特性因故延期,这个版本可能一拖再拖。
当时,Mark 也提出来一种基于时间命名版本号的机制,比如下一个将于 2018 年 3 月发布的版本,就是 18.3,再下一个版本是 18.9,以后版本依此类推。
不过经过讨论,考虑和之前版本号的兼容等问题,最终选择的命名机制是:
$FEATURE.$INTERIM.$UPDATE.$PATCH
$FEATURE:每次版本发布加 1,不考虑具体的版本内容。2018 年 3 月的版本是 JDK 10,9 月的版本是 JDK 11,依此类推。$INTERIM:中间版本号,在大版本中间发布的,包含问题修复和增强的版本,不会引入非兼容性修改。
尽管距离 Java 9 发布仅有六个月的时间,Java 10 的发布也带来了不少新特性和功能增强,以上只是针对其中对开发人员影响重大的主要的一些特性做了介绍,同时也希望下一个 Java 版本能够带来更多、更大的变化。以上只是个人在实际项目中的一点思考,如有不足之处,还望各位读者能够海涵,如可以,希望读者们能够反馈意见,交流心得,一同进步。
本文章转载自 https://developer.ibm.com/zh/technologies/java/articles/the-new-features-of-java-10/
推荐阅读 点击标题可跳转
Docker Desktop 突然宣告收费,网友:是时候弃用了
PS:因为公众号平台更改了推送规则,如果不想错过内容,记得读完点一下“在看”,加个“星标”,这样每次新文章推送才会第一时间出现在你的订阅列表里。
随手在看、转发是最大的支持!
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。