Java for Beginner

Рекомендации по выбору

Когда использовать for-each:
Простой последовательный обход без необходимости модификации
Работа с LinkedList или другими не-RandomAccess коллекциями
Улучшение читаемости кода
Обход массивов когда индекс не нужен
Работа с вложенными структурами

// Идеальный сценарий для for-each
for (Customer customer : customers) {
    sendNotification(customer);
}

Когда использовать индексированный for:
Необходимость доступа к индексу
Обратный или нестандартный обход
Модификация коллекции во время итерации
Пакетная обработка с определенным шагом
Работа с ArrayList или массивами

// Идеальный сценарий для индексированного for
for (int i = 0; i < array.length; i++) {
    if (array[i] == null) {
        array[i] = defaultValue;
    }
}

Гибридные подходы

Использование счетчика с for-each

int index = 0;
for (String item : collection) {
    processWithIndex(item, index);
    index++;
}

Обход с ListIterator

ListIterator<String> iterator = list.listIterator();
while (iterator.hasNext()) {
    String item = iterator.next();
    int index = iterator.previousIndex();
    processWithIndex(item, index);
}

Fail-fast коллекции: философия быстрого отказа

Концепция fail-fast

Fail-fast (быстрый отказ) — это подход к обработке ошибок, при котором система немедленно сообщает о проблеме, как только она обнаружена. В контексте коллекций Java это означает, что итераторы обнаруживают структурные модификации коллекции во время итерации и немедленно выбрасывают исключение.

Механизм реализации

Ключевым элементом fail-fast поведения является поле modCount:

// Пример из AbstractList
protected transient int modCount = 0;

Назначение: Отслеживание количества структурных модификаций коллекции.
Инкрементация: Увеличивается при каждой операции, изменяющей размер или структуру коллекции.
Использование: Сравнивается с сохраненной копией в итераторе.

Реализация в итераторах

private class Itr implements Iterator<E> {
    int expectedModCount = modCount;
    int cursor = 0;
    
    public E next() {
        checkForComodification(); // Проверка изменений
        // ... остальная логика
    }
    
    final void checkForComodification() {
        if (modCount != expectedModCount)
            throw new ConcurrentModificationException();
    }
    
    public void remove() {
        checkForComodification();
        // ... удаление элемента
        expectedModCount = modCount; // Синхронизация после успешного удаления
    }
}

Коллекции с fail-fast семантикой
ArrayList и все его производные
LinkedList
HashSet
HashMap (итераторы entrySet, keySet, values)
TreeMap и TreeSet

Пример поведения

List<String> list = new ArrayList<>(Arrays.asList("A", "B", "C"));

// Попытка модификации во время итерации
for (String item : list) {
    if (item.equals("B")) {
        list.remove(item); // ConcurrentModificationException!
    }
}

Детальный анализ исключения ConcurrentModificationException

Условия возникновения
Структурная модификация: Изменение размера коллекции (add, remove)
Одновременная итерация: Активный итератор или for-each цикл
Разные объекты: Модификация не через текущий итератор

Что считается структурной модификацией

Вызывают исключение:
add(), addAll()
remove(), removeAll(), retainAll(), clear()
set() на определенных позициях в некоторых реализациях

Не вызывают исключение:
set() для замены элемента без изменения размера
Операции через Iterator.remove()
Операции через ListIterator.add(), set(), remove()

Механизм обнаружения изменений

// Упрощенная проверка в ArrayList.Itr
final void checkForComodification() {
    if (modCount != expectedModCount) {
        // Разные стратегии в разных коллекциях
        if (modCount == expectedModCount + 1 && lastRet < 0) {
            // Возможно, это наш собственный remove()
            expectedModCount = modCount;
        } else {
            throw new ConcurrentModificationException();
        }
    }
}

#Java #для_новичков #beginner #for_each #fail_fast #fail_safe

👍2

18 views08:57

Java for Beginner

Стратегии работы с fail-fast коллекциями

Безопасные паттерны

Использование Iterator.remove():

Iterator<String> iterator = list.iterator();
while (iterator.hasNext()) {
    String item = iterator.next();
    if (shouldRemove(item)) {
        iterator.remove(); // Безопасно!
    }
}

Сбор элементов для удаления:

List<String> toRemove = new ArrayList<>();
for (String item : list) {
    if (shouldRemove(item)) {
        toRemove.add(item);
    }
}
list.removeAll(toRemove); // Безопасно вне цикла

Использование индексированного цикла:

for (int i = 0; i < list.size(); i++) {
    if (shouldRemove(list.get(i))) {
        list.remove(i);
        i--; // Корректировка индекса
    }
}

Опасные паттерны (антипаттерны)

Модификация через коллекцию во время итерации:

for (String item : list) {
    list.add("new"); // ConcurrentModificationException!
}

Параллельные модификации из разных потоков:

// Поток 1
for (String item : list) {
    // Итерация
}

// Поток 2
list.add("new"); // ConcurrentModificationException в потоке 1

Преимущества и недостатки fail-fast подхода

Преимущества
Раннее обнаружение ошибок: Проблемы выявляются сразу же
Предсказуемость: Гарантированная consistency во время итерации
Простота отладки: Точное указание на проблему
Защита от тонких багов: Предотвращение незаметной порчи данных

Недостатки
Ограничения на модификации: Нельзя изменять коллекцию во время итерации
Производительность: Дополнительные проверки на каждой операции
Сложность в многопоточных сценариях: Требует внешней синхронизации

Fail-safe коллекции: философия безопасного продолжения

Fail-safe (безопасный отказ) — это подход, при котором система продолжает работу даже при возникновении ошибок или изменений состояния. В контексте коллекций это означает, что итераторы работают с моментальным снимком (snapshot) данных или используют специальные механизмы для обеспечения consistency во время итерации.

Механизмы реализации

Copy-on-write (копирование при записи)
Наиболее распространенный механизм fail-safe:

public class CopyOnWriteArrayList<E> {
    private transient volatile Object[] array;
    
    public Iterator<E> iterator() {
        return new COWIterator<E>(getArray(), 0);
    }
    
    static final class COWIterator<E> implements ListIterator<E> {
        private final Object[] snapshot;
        private int cursor;
        
        COWIterator(Object[] elements, int initialCursor) {
            snapshot = elements; // Снимок на момент создания
            cursor = initialCursor;
        }
        
        public E next() {
            if (!hasNext())
                throw new NoSuchElementException();
            return (E) snapshot[cursor++];
        }
    }
}

Слабая согласованность (weakly consistent)

Альтернативный подход, используемый в concurrent коллекциях:
Итератор видит элементы, существовавшие на момент его создания
Может видеть некоторые, но не все последующие изменения
Не выбрасывает ConcurrentModificationException

Коллекции с fail-safe семантикой

CopyOnWriteArrayList
Принцип работы: При каждой модификации создается новая копия внутреннего массива.

CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<>();

// Безопасная модификация во время итерации
for (String item : list) { // Итератор использует snapshot
    if (condition(item)) {
        list.add("new"); // Не влияет на текущую итерацию
    }
}

ConcurrentHashMap
Принцип работы: Сегментированная блокировка и слабо-консистентные итераторы.

ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<>();

// Итерация по entrySet
for (Map.Entry<String, Integer> entry : map.entrySet()) {
    map.put("newKey", 42); // Безопасно, но может не отобразиться в текущем итераторе
}

ConcurrentLinkedQueue
Принцип работы: Lock-free алгоритмы и weak consistency.

ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<>();

for (String item : queue) {
    queue.offer("new"); // Безопасно
}

#Java #для_новичков #beginner #for_each #fail_fast #fail_safe

👍2

14 views08:57

Java for Beginner

Детальный анализ поведения fail-safe коллекций

CopyOnWriteArrayList: детали реализации
Структура данных:

public class CopyOnWriteArrayList<E> {
    // volatile для обеспечения memory visibility
    private transient volatile Object[] array;
    
    final Object[] getArray() {
        return array;
    }
    
    final void setArray(Object[] a) {
        array = a;
    }
}

Алгоритм добавления элемента:

public boolean add(E e) {
    synchronized(lock) {
        Object[] elements = getArray();
        int len = elements.length;
        
        // Создание новой копии
        Object[] newElements = Arrays.copyOf(elements, len + 1);
        newElements[len] = e;
        
        // Атомарная замена ссылки
        setArray(newElements);
        return true;
    }
}

Характеристики:
Чтение: O(1), без блокировок
Запись: O(n), требует полного копирования
Память: Дополнительная копия во время модификации
Итераторы: Всегда работают с snapshot

ConcurrentHashMap: сегментированная архитектура

Структура (Java 7 и ранее):

public class ConcurrentHashMap<K, V> {
    final Segment<K,V>[] segments; // Массив сегментов
    
    static final class Segment<K,V> extends ReentrantLock {
        transient volatile HashEntry<K,V>[] table;
    }
}

Итерация:

public Iterator<Map.Entry<K,V>> iterator() {
    return new EntryIterator();
}

// Weakly consistent итератор
final class EntryIterator extends HashIterator
    implements Iterator<Entry<K,V>> {
    public Map.Entry<K,V> next() {
        HashEntry<K,V> e = super.nextEntry();
        return new WriteThroughEntry(e.key, e.value);
    }
}

Характеристики:
Чтение: O(1) в среднем, без блокировок
Запись: O(1) в среднем, блокировка только сегмента
Итераторы: Weakly consistent, могут не видеть все изменения

Преимущества и недостатки fail-safe подхода

Преимущества
Безопасность в многопоточных сценариях: Нет необходимости во внешней синхронизации
Отсутствие ConcurrentModificationException: Итерация никогда не прерывается
Высокая производительность чтения: Особенно в read-heavy workload'ах
Простота использования: Меньше требований к синхронизации

Недостатки
Расход памяти: Copy-on-write требует дополнительной памяти
Задержка видимости изменений: Итераторы могут не видеть свежие данные
Производительность записи: Copy-on-write имеет высокую стоимость
Сложность семантики: Weak consistency может быть неинтуитивной

Паттерны использования fail-safe коллекций

Сценарии для CopyOnWriteArrayList
Конфигурационные данные:

public class ConfigurationManager {
    private final CopyOnWriteArrayList<Listener> listeners = 
        new CopyOnWriteArrayList<>();
    
    public void addListener(Listener listener) {
        listeners.add(listener); // Безопасно, даже во время уведомлений
    }
    
    public void notifyListeners() {
        for (Listener listener : listeners) { // Snapshot итератор
            listener.onChange();
        }
    }
}

Кэширование часто читаемых данных:

public class DataCache {
    private volatile CopyOnWriteArrayList<Data> cache = 
        new CopyOnWriteArrayList<>();
    
    public void refreshCache() {
        List<Data> newData = loadData();
        cache = new CopyOnWriteArrayList<>(newData); // Атомарная замена
    }
    
    public List<Data> getData() {
        return cache; // Безопасное чтение
    }
}

Сценарии для ConcurrentHashMap
Кэш с конкурентным доступом:

public class ConcurrentCache<K, V> {
    private final ConcurrentHashMap<K, V> cache = new ConcurrentHashMap<>();
    
    public V get(K key) {
        return cache.get(key); // Без блокировок
    }
    
    public V computeIfAbsent(K key, Function<K, V> loader) {
        return cache.computeIfAbsent(key, loader); // Атомарно
    }
    
    public void processAll() {
        for (Map.Entry<K, V> entry : cache.entrySet()) {
            // Безопасная итерация даже при concurrent модификациях
            processEntry(entry);
        }
    }
}

#Java #для_новичков #beginner #for_each #fail_fast #fail_safe

👍2

25 views08:57

Java for Beginner

Критерии выбора fail-fast и fail-safe

Выбор fail-fast коллекций когда:
Single-threaded окружение или контролируемая многопоточность
Важна немедленная видимость изменений
Ограниченные ресурсы памяти
Частые операции записи
Нужна предсказуемость поведения

// Оптимально для single-threaded сценариев
List<String> singleThreadedList = new ArrayList<>();

Выбор fail-safe коллекций когда:
Высокая конкурентность чтения и записи
Read-heavy workloads
Не критична задержка видимости изменений
Достаточно памяти для copy-on-write
Нужна thread-safe семантика без внешней синхронизации

// Оптимально для многопоточных read-heavy сценариев
List<String> concurrentList = new CopyOnWriteArrayList<>();

Гибридные подходы

Комбинация fail-fast и внешней синхронизации

public class SynchronizedListWrapper {
    private final List<String> list = new ArrayList<>();
    
    public synchronized void safeIteration() {
        // Внутри synchronized блока fail-fast безопасен
        for (String item : list) {
            process(item);
        }
    }
    
    public synchronized void modify() {
        list.add("new");
    }
}

Использование ReadWriteLock

public class ReadWriteProtectedList {
    private final List<String> list = new ArrayList<>();
    private final ReadWriteLock lock = new ReentrantReadWriteLock();
    
    public void iterateSafely() {
        lock.readLock().lock();
        try {
            for (String item : list) {
                process(item); // Безопасное чтение
            }
        } finally {
            lock.readLock().unlock();
        }
    }
    
    public void modifySafely() {
        lock.writeLock().lock();
        try {
            list.add("new"); // Безопасная модификация
        } finally {
            lock.writeLock().unlock();
        }
    }
}

Практические рекомендации и best practices

Общие рекомендации по выбору циклов
Предпочитайте for-each для простого последовательного обхода
Используйте индексированный for когда нужен индекс или нестандартный обход
Избегайте индексированного for для LinkedList
Рассмотрите Stream API для сложных операций фильтрации и трансформации

// For-each для простого обхода
for (Item item : items) {
    process(item);
}

// Индексированный for когда нужен индекс
for (int i = 0; i < items.size(); i++) {
    processWithIndex(items.get(i), i);
}

// Stream API для сложных операций
items.stream()
     .filter(this::shouldProcess)
     .map(this::transform)
     .forEach(this::process);

Рекомендации по работе с fail-fast коллекциями
Не модифицируйте коллекцию во время итерации через методы коллекции
Используйте Iterator.remove() для безопасного удаления
Собирайте изменения отдельно для пакетного применения
Синхронизируйте доступ в многопоточных сценариях

// Безопасный паттерн
List<String> toRemove = new ArrayList<>();
for (String item : list) {
    if (shouldRemove(item)) {
        toRemove.add(item);
    }
}
list.removeAll(toRemove);

Рекомендации по работе с fail-safe коллекциями
Понимайте семантику weak consistency для concurrent коллекций
Учитывайте стоимость copy-on-write для больших коллекций
Используйте для read-heavy workloads
Избегайте частых модификаций больших CopyOnWriteArrayList

// Оптимальное использование CopyOnWriteArrayList
CopyOnWriteArrayList<Data> dataCache = new CopyOnWriteArrayList<>();

// Редкое обновление всего кэша
public void refreshCache() {
    List<Data> freshData = loadFreshData();
    dataCache = new CopyOnWriteArrayList<>(freshData);
}

// Частое чтение
public List<Data> getCachedData() {
    return dataCache;
}

#Java #для_новичков #beginner #for_each #fail_fast #fail_safe

👍2

32 views08:57

Java for Beginner

Что выведет код?

import java.util.*;
import java.util.concurrent.CopyOnWriteArrayList;

public class Task161225 {
    public static void main(String[] args) {
        List<Integer> failFast = new ArrayList<>(Arrays.asList(1, 2, 3));
        List<Integer> failSafe = new CopyOnWriteArrayList<>(Arrays.asList(1, 2, 3));
        
        try {
            for (int num : failFast) {
                System.out.print(num + " ");
                if (num == 2) failFast.add(4);
            }
        } catch (Exception e) {
            System.out.print("FFex ");
        }
        
        try {
            for (int num : failSafe) {
                System.out.print(num + " ");
                if (num == 2) failSafe.add(4);
            }
        } catch (Exception e) {
            System.out.print("FSex ");
        }
        
        System.out.print(failFast.size() + " ");
        System.out.print(failSafe.size());
    }
}

#Tasks

👍1

54 views11:57

Java for Beginner

Варианты ответа:

Anonymous Quiz

22%

1 2 FFex 1 2 3 FSex 3 4

😱1

9 voters57 views12:01

Java for Beginner

Spring Cloud Gateway: граница микросервисов.

Если рискнете посмотреть сегодняшнее видео, то скорее всего приобретете неплохую компетенцию по Spring Cloud Gateway.

Что я там показал и о чем рассказал:
🔵Зачем вообще нам Gateway и что это такое.
🔵Как происходит роутинг и как это настроить в mvc и webflux версиях.
🔵Что такое предикаты, фильтры, и что они могут.
🔵Как всегда немного подебажил))

Репозиторий на GitHub очень ждет Ваших звезд. Хотя-бы зацените как я для Вас постарался.

☺️

Ссылка на Youtube
Ссылка на Рутьюб

Смотрите, ставьте лайки, подписывайтесь на каналы!✌️

Please open Telegram to view this post

VIEW IN TELEGRAM

🔥6🆒11

55 viewsedited 13:57

Java for Beginner

Вопрос с собеседований

Что такое pessimistic locking?

🤓

Ответ:

Пессимистичная блокировка предполагает высокую вероятность конфликта.

Данные блокируются сразу при чтении. Это гарантирует безопасность, но снижает производительность.

Часто используется в базах данных для защиты от одновременных обновлений.

#собеседование

Please open Telegram to view this post

VIEW IN TELEGRAM

👍3

46 views15:57

About

Blog

Apps

Platform