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

27 views08:57