Java for Beginner

Comparable и Comparator. Нюансы использования Comparable

Неизменяемость порядка
Если класс реализует Comparable, его порядок сортировки должен быть неизменным. Например, изменение поля, по которому происходит сортировка, после добавления объекта в отсортированную коллекцию (например, TreeSet), может нарушить инварианты коллекции.

Совместимость с equals
Желательно, чтобы compareTo был согласован с equals. Это значит, что если a.compareTo(b) == 0, то a.equals(b) должно быть true. Нарушение этого правила может привести к неожиданному поведению в коллекциях, таких как TreeSet или TreeMap.

Пример проблемы:

public class Person implements Comparable { 

private String name; private int age;

   @Override
   public int compareTo(Person other) {
       return this.name.compareTo(other.name); // Сравнение только по имени
   }

   @Override
   public boolean equals(Object obj) {
       if (!(obj instanceof Person)) return false;
       Person other = (Person) obj;
       return this.name.equals(other.name) && this.age == other.age;
   }

}

Здесь compareTo считает объекты равными, если совпадают имена, но equals требует совпадения и возраста. Это может вызвать проблемы в TreeSet, где два объекта с одинаковым именем, но разным возрастом будут считаться одинаковыми.

Null-обработка
Метод compareTo должен корректно обрабатывать null, иначе возможен NullPointerException.

Например:

@Override public int compareTo(Person other) {
    if (other == null) return 1; // null считается "меньше" return this.age - other.age; 
}

Нюансы использования Comparator

Гибкость и переиспользование
Comparator можно создавать динамически, что делает его более гибким.

Например, для одноразовой сортировки можно использовать лямбда-выражение:

List people = new ArrayList<>(); 

Collections.sort(people, (p1, p2) -> p2.getAge() - p1.getAge()); // Сортировка по убыванию возраста

Null-обработка
Comparator должен учитывать возможность null-значений.

Java 8 предоставляет методы для упрощения работы с null:

Comparator nullSafeComparator = Comparator .nullsFirst(Comparator.comparing(Person::getName)); // null-объекты будут первыми

Производительность
Частое создание новых объектов Comparator (например, в цикле) может быть неэффективным. Лучше сохранять и переиспользовать экземпляры Comparator.

Типичные ошибки

Несогласованность сравнений
Если compareTo или compare нарушают транзитивность (например, a < b и b < c, но a > c), сортировка может завершиться с ошибкой.

Использование вычитания для чисел
Вместо this.age - other.age лучше использовать Integer.compare(this.age, other.age), чтобы избежать переполнения при больших числах.

Игнорирование контракта
Реализация compareTo или compare должна быть рефлексивной, симметричной и транзитивной.

#Java #Training #Medium #Comparable #Comparator

118 views05:59

Java for Beginner

Comparable и Comparator. Практические примеры и рекомендации

Пример 1: Сортировка с учетом нескольких полей

Допустим, у нас есть класс Employee, который нужно сортировать сначала по отделу, а затем по зарплате:

public class Employee { 

private String department; 
private double salary;

public Employee(String department, double salary) {
    this.department = department;
    this.salary = salary;
}

public String getDepartment() { return department; }
public double getSalary() { return salary; }

@Override
public String toString() {
    return department + ": " + salary;
  }

}

Сортировка с использованием Comparator:

List employees = new ArrayList<>(); 

employees.add(new Employee("HR", 50000)); 
employees.add(new Employee("IT", 60000)); 
employees.add(new Employee("HR", 45000));

Comparator comparator = Comparator.comparing(Employee::getDepartment).thenComparingDouble(Employee::getSalary);

Collections.sort(employees, comparator); 

System.out.println(employees); // Вывод: [HR: 45000.0, HR: 50000.0, IT: 60000.0]

Пример 2: Обратная сортировка

Для сортировки в обратном порядке можно использовать reversed():

Comparator reverseComparator = Comparator.comparingDouble(Employee::getSalary).reversed();

Collections.sort(employees, reverseComparator); 

System.out.println(employees); // Вывод: [IT: 60000.0, HR: 50000.0, HR: 45000.0]

Пример 3: Использование в TreeSet

TreeSet автоматически поддерживает порядок элементов, используя Comparable или Comparator:

TreeSet employeeSet = new TreeSet<>(Comparator.comparing(Employee::getDepartment).thenComparingDouble(Employee::getSalary)); 

employeeSet.add(new Employee("HR", 50000)); 
employeeSet.add(new Employee("IT", 60000)); 
employeeSet.add(new Employee("HR", 45000)); 

System.out.println(employeeSet); // Вывод: [HR: 45000.0, HR: 50000.0, IT: 60000.0]

Рекомендации

Выбирайте Comparable для естественного порядка
Если класс имеет очевидный порядок (например, числа, строки), реализуйте Comparable. Это упрощает использование класса в стандартных коллекциях.

Используйте Comparator для гибкости
Для альтернативных порядков или классов, которые нельзя модифицировать, создавайте отдельные Comparator.

Пользуйтесь Java 8+
Методы Comparator.comparing(), thenComparing() и лямбда-выражения значительно упрощают код.

Тестируйте сортировку
Убедитесь, что реализация compareTo и compare корректно обрабатывает краевые случаи (null, равные объекты, экстремальные значения).

Избегайте модификации отсортированных коллекций
Если объект в TreeSet или TreeMap изменяется так, что нарушается порядок, это может привести к некорректной работе коллекции.

#Java #Training #Medium #Comparable #Comparator

126 views14:59

Java for Beginner

Collectors в Java

Collectors в Java — это утилитный класс из пакета java.util.stream, введенный в Java 8 вместе с Stream API. Он предоставляет готовые реализации для выполнения операций сведения (reduction) над потоками данных. Основная задача Collectors — собирать элементы потока в коллекции, выполнять группировку, агрегацию или другие преобразования. Collectors используется в методе Stream.collect(), который является терминальной операцией, завершающей обработку потока.

Класс Collectors содержит статические методы, возвращающие объекты типа Collector<T, A, R>, где:
T — тип элементов в потоке.
A — тип промежуточного аккумулятора, используемого для накопления данных.
R — тип результата, который возвращается после обработки.

Collectors упрощает работу с потоками, предоставляя готовые решения для типичных задач, таких как сбор элементов в список, множество, словарь, группировка по ключу или подсчет статистики. Без Collectors пришлось бы вручную реализовывать сложную логику с использованием собственных аккумуляторов.

Collector состоит из четырех ключевых компонентов:
Supplier: создает начальный аккумулятор (например, новый ArrayList).
Accumulator: добавляет элемент потока в аккумулятор.
Combiner: объединяет два аккумулятора (используется в параллельных потоках).
Finisher: преобразует аккумулятор в конечный результат (например, возвращает коллекцию).

Пример простого использования:

import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class CollectorsExample {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("apple", "banana", "orange");
        List<String> list = stream.collect(Collectors.toList());
        System.out.println(list); // [apple, banana, orange]
    }
}

Collectors часто используется для:
Сбора элементов в коллекции (List, Set, Map).
Группировки данных (groupingBy).
Объединения строк (joining).
Вычисления статистик (summingInt, averagingDouble).

#Java #Training #Medium #Collectors

122 views05:59

Java for Beginner

Collectors в Java

Collectors.toList

Collectors.toList() собирает элементы потока в List. Реализация по умолчанию возвращает ArrayList, но конкретная реализация не гарантируется и может измениться. Это один из самых простых и часто используемых коллекторов.

Пример:

import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class ToListExample {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("apple", "banana", "orange");
        List<String> list = stream.collect(Collectors.toList());
        System.out.println(list); // [apple, banana, orange]
    }
}

Внутренне toList использует:
Supplier: new ArrayList<>()
Accumulator: list.add(element)
Combiner: list1.addAll(list2)
Finisher: возвращает сам аккумулятор (identity функция).

Особенности:
Сохраняет порядок элементов (если поток упорядочен).
Допускает дубликаты.
Не поддерживает настройку типа List (для этого есть toCollection).

Collectors.toSet

Collectors.toSet() собирает элементы потока в Set, по умолчанию возвращая HashSet. Как и в случае с toList, конкретная реализация не гарантируется.

Пример:

import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class ToSetExample {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("apple", "banana", "apple");
        Set<String> set = stream.collect(Collectors.toSet());
        System.out.println(set); // [apple, banana]
    }
}

Внутренне toSet использует:
Supplier: new HashSet<>()
Accumulator: set.add(element)
Combiner: set1.addAll(set2)
Finisher: возвращает аккумулятор.

Особенности:
Удаляет дубликаты (Set не допускает повторяющихся элементов).
Не гарантирует порядок элементов (HashSet не сохраняет порядок).
Для упорядоченного множества можно использовать toCollection(TreeSet::new).

#Java #Training #Medium #Collectors #CollectorsToList #CollectorsToSet

129 views14:59

Java for Beginner

Collectors в Java

Collectors.toMap

Collectors.toMap – это мощный коллектор, преобразующий элементы потока в Map<K, V>, где ключи и значения вычисляются на основе элементов потока.

1. Базовая форма: toMap(keyMapper, valueMapper)

Преобразует поток в Map, где:
keyMapper – функция, вычисляющая ключ,
valueMapper – функция, вычисляющая значение.

Сигнатура:

public static <T, K, U> Collector<T, ?, Map<K, U>> toMap(  
    Function<? super T, ? extends K> keyMapper,  
    Function<? super T, ? extends U> valueMapper  
)

Пример:

List<String> names = List.of("Alice", "Bob", "Charlie");  

// Создаем Map: {имя -> длина строки}  
Map<String, Integer> nameToLength = names.stream()  
    .collect(Collectors.toMap(  
        name -> name,            // ключ – сама строка  
        name -> name.length()    // значение – длина строки  
    ));  

// Результат: {"Alice":5, "Bob":3, "Charlie":7}
Что произойдет, если ключи повторяются?
→ Будет выброшено IllegalStateException!

2. Обработка дубликатов: toMap(keyMapper, valueMapper, mergeFunction)

Если возможны повторяющиеся ключи, нужно указать mergeFunction – стратегию разрешения конфликтов.

Сигнатура:

public static <T, K, U> Collector<T, ?, Map<K, U>> toMap(  
    Function<? super T, ? extends K> keyMapper,  
    Function<? super T, ? extends U> valueMapper,  
    BinaryOperator<U> mergeFunction  
)

Примеры:

2.1. Оставить старое значение

List<String> names = List.of("Alice", "Bob", "Alice");  

Map<String, Integer> nameToLength = names.stream()  
    .collect(Collectors.toMap(  
        name -> name,  
        name -> name.length(),  
        (oldValue, newValue) -> oldValue  // при конфликте берем старое значение  
    ));  

// Результат: {"Alice":5, "Bob":3}

2.2. Объединить значения (например, конкатенация строк)

List<String> names = List.of("A", "B", "A", "C");  

Map<String, String> mergedLetters = names.stream()  
    .collect(Collectors.toMap(  
        letter -> letter,  
        letter -> letter,  
        (oldVal, newVal) -> oldVal + newVal  // "A" + "A" → "AA"  
    ));  

// Результат: {"A":"AA", "B":"B", "C":"C"}

2.3. Суммирование значений при дублировании ключей

record Product(String id, double price) {}  

List<Product> products = List.of(  
    new Product("A", 10.0),  
    new Product("B", 20.0),  
    new Product("A", 15.0)  
);  

Map<String, Double> totalPriceById = products.stream()  
    .collect(Collectors.toMap(  
        Product::id,  
        Product::price,  
        Double::sum  // 10.0 + 15.0 = 25.0  
    ));  

// Результат: {"A":25.0, "B":20.0}

3. Выбор реализации Map: toMap(keyMapper, valueMapper, mergeFunction, mapFactory)

Позволяет указать конкретную реализацию Map (например, LinkedHashMap или TreeMap).

Сигнатура:

public static <T, K, U, M extends Map<K, U>> Collector<T, ?, M> toMap(  
    Function<? super T, ? extends K> keyMapper,  
    Function<? super T, ? extends U> valueMapper,  
    BinaryOperator<U> mergeFunction,  
    Supplier<M> mapFactory  
)

Примеры:

3.1. Сохранение порядка вставки (LinkedHashMap)

Map<String, Integer> orderedMap = names.stream()  
    .collect(Collectors.toMap(  
        name -> name,  
        name -> name.length(),  
        (oldVal, newVal) -> oldVal,  
        LinkedHashMap::new  
    ));

3.2. Сортировка по ключу (TreeMap)

Map<String, Integer> sortedMap = names.stream()  
    .collect(Collectors.toMap(  
        name -> name,  
        name -> name.length(),  
        (oldVal, newVal) -> oldVal,  
        TreeMap::new  
    ));

#Java #Training #Medium #Collectors #CollectorsToMap

120 views05:59

Java for Beginner

4. Особенности и подводные камни

4.1. Null-ключи и Null-значения
HashMap допускает один null-ключ, но если keyMapper возвращает null – будет NullPointerException.
Если valueMapper возвращает null, значение в Map будет null.

4.2. Параллельные стримы
toMap не оптимизирован для параллельных операций.
Вместо него лучше использовать Collectors.toConcurrentMap.

4.3. Изменяемые ключи
Если ключ изменяется после добавления в Map, это может нарушить работу HashMap (ключи должны быть immutable).

5. Альтернативы

5.1. Collectors.toUnmodifiableMap (Java 10+)
Создает неизменяемую Map:

Map<String, Integer> unmodifiableMap = names.stream()  
    .collect(Collectors.toUnmodifiableMap(  
        name -> name,  
        name -> name.length()  
    ));

5.2. Collectors.toConcurrentMap
Оптимизирован для многопоточности:

ConcurrentMap<String, Integer> concurrentMap = names.stream()  
    .collect(Collectors.toConcurrentMap(  
        name -> name,  
        name -> name.length()  
    ));

#Java #Training #Medium #Collectors #CollectorsToMap

123 views05:59

Java for Beginner

Collectors в Java

groupingBy

Collectors.groupingBy – один из самых мощных коллекторов в Java Stream API, позволяющий группировать элементы потока по заданному критерию. Возвращает Map<K, List<T>>, где ключ (K) – это значение классификатора, а значение – список элементов, соответствующих этому ключу.

1. Базовая форма: groupingBy(classifier)
Группирует элементы по ключу, возвращаемому classifier (функцией классификации).

Сигнатура:

public static <T, K> Collector<T, ?, Map<K, List<T>>> groupingBy(  
    Function<? super T, ? extends K> classifier  
)

Пример:

List<String> names = List.of("Alice", "Bob", "Charlie", "Anna", "Alex");  

Map<Integer, List<String>> groupedByLength = names.stream()  
    .collect(Collectors.groupingBy(String::length));  

// Результат:
// {3=[Bob], 4=[Anna, Alex], 5=[Alice], 7=[Charlie]}

Как это работает внутри?

Классификатор (String::length) вычисляет ключ для каждого элемента.
Элементы с одинаковым ключом добавляются в List<T>.
По умолчанию используется HashMap, а значения хранятся в ArrayList.

2. groupingBy(classifier, downstream) – с дополнительным коллектором
Позволяет указать, как собирать элементы в группы (не только в List).

Сигнатура:

public static <T, K, A, D> Collector<T, ?, Map<K, D>> groupingBy(  
    Function<? super T, ? extends K> classifier,  
    Collector<? super T, A, D> downstream  
)

Примеры:

2.1. Группировка в Set вместо List

Map<Integer, Set<String>> groupedByLength = names.stream()  
    .collect(Collectors.groupingBy(  
        String::length,  
        Collectors.toSet()  
    ));

2.2. Подсчет количества элементов в каждой группе

Map<Integer, Long> countByLength = names.stream()  
    .collect(Collectors.groupingBy(  
        String::length,  
        Collectors.counting()  
    ));  
// Результат: {3=1, 4=2, 5=1, 7=1}

2.3. Объединение элементов в строку

Map<Integer, String> joinedNames = names.stream()  
    .collect(Collectors.groupingBy(  
        String::length,  
        Collectors.joining(", ")  
    ));  

// Результат: {3="Bob", 4="Anna, Alex", 5="Alice", 7="Charlie"}

3. groupingBy(classifier, mapFactory, downstream) – с выбором реализации Map
Позволяет указать конкретную реализацию Map (например, TreeMap или LinkedHashMap).

Сигнатура:

public static <T, K, D, A, M extends Map<K, D>> Collector<T, ?, M> groupingBy(  
    Function<? super T, ? extends K> classifier,  
    Supplier<M> mapFactory,  
    Collector<? super T, A, D> downstream  
)

Пример:

// Группировка с сохранением порядка (LinkedHashMap)  
LinkedHashMap<Integer, List<String>> orderedGroups = names.stream()  
    .collect(Collectors.groupingBy(  
        String::length,  
        LinkedHashMap::new,  
        Collectors.toList()  
    ));  

// Группировка с сортировкой по ключу (TreeMap)  
TreeMap<Integer, Set<String>> sortedGroups = names.stream()  
    .collect(Collectors.groupingBy(  
        String::length,  
        TreeMap::new,  
        Collectors.toSet()  
    ));

4. Многокритериальная группировка (вложенные groupingBy)
Можно группировать по нескольким уровням, создавая сложные структуры данных.

Пример:

record Person(String name, String city, int age) {}  

List<Person> people = List.of(  
    new Person("Alice", "NY", 25),  
    new Person("Bob", "LA", 30),  
    new Person("Charlie", "NY", 25),  
    new Person("David", "LA", 35)  
);  

// Группировка по городу, а затем по возрасту  
Map<String, Map<Integer, List<Person>>> multiLevelGroup = people.stream()  
    .collect(Collectors.groupingBy(  
        Person::city,  
        Collectors.groupingBy(Person::age)  
    ));  

// Результат:
// {
//   "NY": {25=[Alice, Charlie]},
//   "LA": {30=[Bob], 35=[David]}
// }

5. Производительность и особенности

Порядок элементов в группах зависит от исходного потока (если он ordered, как в List, порядок сохраняется).
Хэш-коллизии обрабатываются через HashMap.

Нюансы при параллельных стримах:
Если используется ConcurrentHashMap, группировка становится потокобезопасной.
В некоторых случаях groupingByConcurrent работает быстрее.

#Java #Training #Medium #Collectors #groupingBy

138 views14:59

Java for Beginner

Collectors в Java

Collectors.summingInt

Collectors.summingInt — это специализированный коллектор, предназначенный для суммирования целочисленных значений, извлекаемых из элементов потока. Он особенно полезен, когда нужно вычислить общую сумму числовых характеристик объектов.

1. Базовая форма и назначение

Сигнатура:

public static <T> Collector<T, ?, Integer> summingInt(ToIntFunction<? super T> mapper)

Где:

mapper — функция, преобразующая элемент потока в int (значение, которое нужно суммировать)
Возвращает коллектор, который применяет эту функцию ко всем элементам и суммирует результаты

Пример:

List<Product> products = List.of(
    new Product("Laptop", 1000),
    new Product("Phone", 500),
    new Product("Tablet", 300)
);

int totalPrice = products.stream()
    .collect(Collectors.summingInt(Product::getPrice));

// Результат: 1800 (1000 + 500 + 300)

2. Внутренняя реализация

Коллектор работает по следующему алгоритму:
Использует промежуточный аккумулятор типа int[] (для мутабельного накопления суммы)
Для каждого элемента применяет mapper и добавляет результат в аккумулятор
В конце возвращает итоговую сумму

3. Особенности и ограничения

3.1. Только для примитивных int

Для long используйте summingLong
Для double — summingDouble

3.2. Нет обработки null

Если mapper возвращает null, будет NullPointerException

3.3. Параллельные стримы

Корректно работает в параллельных стримах благодаря атомарному накоплению

4. Альтернативы

4.1. Через mapToInt() + sum()

Более прямолинейный способ:

int total = products.stream()
    .mapToInt(Product::getPrice)
    .sum();

Плюсы:
Чуть лучше производительность
Более явное преобразование типов

Минусы:
Нельзя использовать в комбинации с другими коллекторами (например, при группировке)

4.2. reduce()

int total = products.stream()
    .reduce(0, (sum, p) -> sum + p.getPrice(), Integer::sum);

5. Комбинирование с другими коллекторами

Особенно полезно в groupingBy для агрегации:

Map<String, Integer> totalPriceByCategory = products.stream()
    .collect(Collectors.groupingBy(
        Product::getCategory,
        Collectors.summingInt(Product::getPrice)
    ));

Пример вывода:

{
  "Electronics": 1800,
  "Office": 750
}

6. Производительность

Для примитивов (summingInt) работает быстрее, чем reduce с Integer
В HotSpot JIT-компилятор может оптимизировать до прямого сложения

#Java #Training #Medium #Collectors #summingInt

139 views05:59

Java for Beginner

Collectors в Java

Collectors.joining

Collectors.joining – это специализированный коллектор для конкатенации строковых представлений элементов потока в единую строку. Это мощный инструмент для работы с текстовыми данными в Java Stream API.

1. Базовая форма: joining()

Конкатенирует элементы без разделителей.

Сигнатура:

public static Collector<CharSequence, ?, String> joining()

Пример:

List<String> words = List.of("Java", "Stream", "API");
String result = words.stream().collect(Collectors.joining());

// Результат: "JavaStreamAPI"

Особенности:
Работает только с CharSequence (String, StringBuilder и др.)
Если поток пуст, возвращает пустую строку ""

2. С разделителем: joining(delimiter)

Добавляет указанный разделитель между элементами.

Сигнатура:

public static Collector<CharSequence, ?, String> joining(CharSequence delimiter)

Пример:

String result = words.stream().collect(Collectors.joining(", "));

// Результат: "Java, Stream, API"

Применение:
CSV-форматирование
Построение SQL-запросов
Логирование коллекций

3. Полная форма: joining(delimiter, prefix, suffix)

Добавляет префикс и суффикс к результату.

Сигнатура:

public static Collector<CharSequence, ?, String> joining(
    CharSequence delimiter,
    CharSequence prefix,
    CharSequence suffix
)

Пример:

String result = words.stream()
    .collect(Collectors.joining(", ", "[", "]"));

// Результат: "[Java, Stream, API]"

Типичные сценарии:
JSON-массивы: joining(", ", "[", "]")
SQL IN-условия: joining("', '", "'", "'") → 'Java', 'Stream', 'API'
Форматированные списки

4. Внутренняя реализация

Коллектор использует StringJoiner внутри:

StringJoiner joiner = new StringJoiner(delimiter, prefix, suffix);
stream.forEach(element -> joiner.add(element.toString()));
return joiner.toString();

Особенности работы:
Для пустого потока возвращает prefix + suffix (например, "[]")
Оптимизирован для String (избегает лишних преобразований)
В параллельных стримах работает корректно (слияние через StringJoiner.merge)

5. Работа с не-строковыми объектами

Если элементы не являются строками, нужно преобразовать их явно:

List<Integer> numbers = List.of(1, 2, 3);
String result = numbers.stream()
    .map(Object::toString)
    .collect(Collectors.joining("-"));

// Результат: "1-2-3"

Альтернатива через Collectors.mapping:

String result = numbers.stream()
    .collect(Collectors.mapping(
        Object::toString,
        Collectors.joining("/")
    ));

6. Ограничения и нюансы

Null-элементы:
Вызывают NullPointerException

Решение – фильтрация:

.filter(Objects::nonNull)

Большие объемы данных:
Для гигантских потоков лучше использовать StringBuilder напрямую

Локализация:
Нет встроенной поддержки (для чисел/дат используйте NumberFormat перед joining)

7. Комбинирование с другими коллекторами

Группировка с объединением:

Map<String, String> joinedByCategory = products.stream()
    .collect(Collectors.groupingBy(
        Product::getCategory,
        Collectors.mapping(
            Product::getName,
            Collectors.joining(", ")
        )
    ));

Результат:

{
  "Electronics": "Laptop, Phone",
  "Office": "Pen, Paper"
}

Многоуровневое объединение:

String complex = persons.stream()
    .collect(Collectors.mapping(
        p -> p.name() + " (" + p.age() + ")",
        Collectors.joining("; ", "Persons: ", ".")
    ));

// Результат: "Persons: Alice (25); Bob (30)."

8. Альтернативы

StringBuilder (для сложных сценариев):

StringBuilder sb = new StringBuilder();
list.forEach(sb::append);

String.join() (только для List<String>):

String.join(", ", words);

TextBlocks (Java 15+ для многострочных данных):

String sql = """
    SELECT %s
    FROM table
    WHERE id IN (%s)
    """.formatted(
        columns.stream().collect(joining(", ")),
        ids.stream().map(Object::toString).collect(joining(", "))
    );

#Java #Training #Medium #Collectors #joining

139 views14:59

Java for Beginner

Collectors в Java

Collectors.partitioningBy

Collectors.partitioningBy – это специальный коллектор, который разделяет элементы потока на две группы с помощью предиката.

Результатом всегда является Map<Boolean, List<T>>, где:
true – элементы, удовлетворяющие условию
false – элементы, не удовлетворяющие условию

1. Базовая форма: partitioningBy(predicate)
Разделяет элементы на две группы без дополнительной обработки.

Сигнатура:

public static <T> Collector<T, ?, Map<Boolean, List<T>>> partitioningBy(
    Predicate<? super T> predicate
)

Пример:

List<Integer> numbers = List.of(1, 2, 3, 4, 5);

Map<Boolean, List<Integer>> partitioned = numbers.stream()
    .collect(Collectors.partitioningBy(n -> n % 2 == 0));

// Результат:
// {
//   false=[1, 3, 5],
//   true=[2, 4]
// }

Особенности:
Всегда возвращает обе группы (даже если одна пустая)
Сохраняет порядок элементов, если поток упорядочен

2. Расширенная форма: partitioningBy(predicate, downstream)
Позволяет дополнительно обработать каждую группу с помощью другого коллектора.

Сигнатура:

public static <T, D, A> Collector<T, ?, Map<Boolean, D>> partitioningBy(
    Predicate<? super T> predicate,
    Collector<? super T, A, D> downstream
)

Примеры применения:

2.1. Подсчет количества элементов в каждой группе

Map<Boolean, Long> countByPartition = numbers.stream()
    .collect(Collectors.partitioningBy(
        n -> n % 2 == 0,
        Collectors.counting()
    ));

// Результат: {false=3, true=2}

2.2. Объединение элементов в строку

Map<Boolean, String> joinedPartitions = numbers.stream()
    .collect(Collectors.partitioningBy(
        n -> n % 2 == 0,
        Collectors.mapping(
            Object::toString,
            Collectors.joining("-")
        )
    ));

// Результат: {false="1-3-5", true="2-4"}

2.3. Группировка в Set вместо List

Map<Boolean, Set<Integer>> toSet = numbers.stream()
    .collect(Collectors.partitioningBy(
        n -> n % 2 == 0,
        Collectors.toSet()
    ));

3. Внутренняя реализация
Коллектор работает по следующему алгоритму:
Создает Map<Boolean, List<T>> с двумя ключами (true/false)
Для каждого элемента применяет предикат и добавляет в соответствующую группу
Если указан downstream-коллектор, применяет его к каждой группе

Псевдокод реализации:

Map<Boolean, A> result = new HashMap<>();
result.put(true, new ArrayList<>());
result.put(false, new ArrayList<>());

stream.forEach(item -> {
    boolean key = predicate.test(item);
    result.get(key).add(item);
});

// Если есть downstream:
result.replaceAll((k, v) -> downstream.finisher().apply(v));

4. Практические примеры
4.1. Разделение пользователей по возрасту

record Person(String name, int age) {}

List<Person> people = List.of(
    new Person("Alice", 25),
    new Person("Bob", 17),
    new Person("Charlie", 30)
);

Map<Boolean, List<Person>> adults = people.stream()
    .collect(Collectors.partitioningBy(p -> p.age() >= 18));

// Результат:
// {
//   false=[Person[name=Bob, age=17]],
//   true=[Person[name=Alice, age=25], Person[name=Charlie, age=30]]
// }

4.2. Статистика по разделенным группам

Map<Boolean, IntSummaryStatistics> stats = numbers.stream()
    .collect(Collectors.partitioningBy(
        n -> n % 2 == 0,
        Collectors.summarizingInt(Integer::intValue)
    ));

// Получить среднее для четных чисел:
double avgEven = stats.get(true).getAverage();

5. Ограничения и нюансы
Неизменяемость результатов:
Возвращаемые коллекции можно модифицировать (обычно ArrayList)

Для неизменяемых групп использовать collectingAndThen:

.collect(Collectors.collectingAndThen(
    Collectors.partitioningBy(predicate),
    Collections::unmodifiableMap
));

Параллельные стримы:
Работает корректно в параллельных стримах
Группы объединяются через Map.merge

Null-значения:
Предикат должен обрабатывать null (иначе NPE)

Решение:

.partitioningBy(item -> item != null && predicate.test(item))

#Java #Training #Medium #Collectors #partitioningBy

140 views05:59

About

Blog

Apps

Platform