java 8 - Leo Dev Blog

ParallelStream и Stream в Java 8 vs Java10 test

Профилирование времени выполнения Stream против ParallelStream в java 8
#JDK8 [20_000_000 integers] #Corei7 4790 #Windows10
#JDK10 [20_000_000 integers] #Corei7 4790 #Windows10

Помните, используя параллельные стримы мы можем забрать все ресурсы у процессора и нашему веб контейнеру ничего не останется что приведет к торможению работы сервиса

Читать далее «ParallelStream и Stream в Java 8 vs Java10 test»

Сортировка Map по значению

Столкнулся с задачей достать из Map последние 3 дня с наибольшей температурой. Сортировкой по значению это сделать проще всего

 /**
     * Map Sorting by value java 7
     */
    public static <K, V extends Comparable<? super V>> Map<K, V> sortByValue7(Map<K, V> map) {
        List<Map.Entry<K, V>> list = new LinkedList<>(map.entrySet());
        Collections.sort(list, new Comparator<Map.Entry<K, V>>() {
            @Override
            public int compare(Map.Entry<K, V> o1, Map.Entry<K, V> o2) {
                return (o1.getValue()).compareTo(o2.getValue());
            }
        });

        Map<K, V> result = new LinkedHashMap<>();
        for (Map.Entry<K, V> entry : list) {
            result.put(entry.getKey(), entry.getValue());
        }
        return result;
    }

    /**
     * Map Sorting by value java 8
     */
    public static <K, V extends Comparable<? super V>> Map<K, V> sortByValue8(Map<K, V> map) {
        Map<K, V> result = new LinkedHashMap<>();
        Stream<Map.Entry<K, V>> st = map.entrySet().stream();
        st.sorted(Comparator.comparing(e -> e.getValue())).forEach(e -> result.put(e.getKey(), e.getValue()));
        return result;
    }

/**

* Map Sorting by value java 7

public static <K, V extends Comparable<? super V>> Map<K, V> sortByValue7(Map<K, V> map) {

List<Map.Entry<K, V>> list = new LinkedList<>(map.entrySet());

Collections.sort(list, new Comparator<Map.Entry<K, V>>() {

@Override

public int compare(Map.Entry<K, V> o1, Map.Entry<K, V> o2) {

return (o1.getValue()).compareTo(o2.getValue());

}

});

Map<K, V> result = new LinkedHashMap<>();

for (Map.Entry<K, V> entry : list) {

result.put(entry.getKey(), entry.getValue());

}

return result;

}

/**

* Map Sorting by value java 8

public static <K, V extends Comparable<? super V>> Map<K, V> sortByValue8(Map<K, V> map) {

Map<K, V> result = new LinkedHashMap<>();

Stream<Map.Entry<K, V>> st = map.entrySet().stream();

st.sorted(Comparator.comparing(e -> e.getValue())).forEach(e -> result.put(e.getKey(), e.getValue()));

return result;

}

Методы java.util.concurrent.CompletableFuture

Начиная с Java8 в библиотеке появился класс CompletableFuture — это средство для передачи информации между параллельными потоками исполнения. Говоря проще это блокирующая очередь, способная передать только одно ссылочное значение. В отличие от обычной очереди, передает также исключение, если оно возникло при вычислении передаваемого значения.

Класс содержит несколько десятков методов, в которых легко потеряться. Данная статья классифицирует эти методы по нескольким признакам, чтобы в них было легко ориентироваться.

Для разминки познакомимся с новыми интерфейсами из пакета java.util.Function, которые используются как типы параметров во многих методах. Читать далее «Методы java.util.concurrent.CompletableFuture»