Какво можете да разкажете за многопоточните колекции…

Колекциите с множество нишки в Java предоставят безопасни начини за работа с данни от няколко нишки едновременно, предотвратявайки състезателни условия и други проблеми със синхронизацията.

Основните интерфейси и класове включват:

ConcurrentMap: Разширява Map и осигурява атомарни операции.
- ConcurrentHashMap: Високопроизводителна реализация, която не блокира цялата карта при модификация. Осигурява безопасност за нишки без пълно блокиране.
CopyOnWriteArrayList и CopyOnWriteArraySet: Колекции, безопасни за нишки, които създават копие на основния масив при всяка модификация. Подходящи за колекции, които често се четат и рядко се променят. Четенето става без блокиране.
BlockingQueue: Интерфейс на опашка, поддържащ операции на изчакване, докато опашката не стане празна или пълна. Използва се за организиране на взаимодействие между нишки, например в модел producer-consumer.
- ArrayBlockingQueue: Реализация на BlockingQueue на базата на масив с фиксирана капацитет.
- LinkedBlockingQueue: Реализация на BlockingQueue на базата на свързан списък с опционална капацитет.
- SynchronousQueue: Опашка с нулев капацитет. Всяка операция по вмъкване чака съответната операция по извличане и обратното.
ConcurrentLinkedQueue: Безопасна за нишки реализация на Queue на базата на свързан списък. Не поддържа блокиращи операции.

Различията от синхронизирани колекции (Collections.synchronizedList, Collections.synchronizedMap и др.):

Синхронизирани колекции използват пълно блокиране на ниво обект, което може да намали производителността при висока конкуренция.
Колекциите с множество нишки, като ConcurrentHashMap, използват по-фино блокиране или други механизми за постигане на по-добра производителност.
Итераторите на синхронизирани колекции могат да хвърлят ConcurrentModificationException при модификация на колекцията по време на итерация от друга нишка. Итераторите на колекциите с множество нишки обикновено са по-устойчиви на такива промени.

Изборът на конкретна колекция с множество нишки зависи от сценария на използване: честота на четене/писане, необходимост от блокиращи операции, изисквания за производителност и др.

Пример за използване на ConcurrentHashMap:

import java.util.concurrent.ConcurrentHashMap;

public class ConcurrentExample {

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

    public void updateValue(String key, Integer value) {
        map.put(key, value); // Безопасна за нишки операция
    }

    public Integer getValue(String key) {
        return map.get(key); // Безопасна за нишки операция
    }

    public void incrementValue(String key) {
        // Атомична операция: ако ключът не съществува, ще постави 1, иначе ще увеличи съществуващата стойност
        map.compute(key, (k, v) -> (v == null) ? 1 : v + 1);
    }
}

Пример за използване на BlockingQueue:

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;

public class ProducerConsumer {

    private final BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);

    // Производител
    public void produce(Integer item) throws InterruptedException {
        queue.put(item); // Блокира, ако опашката е пълна
        System.out.println("Produced: " + item);
    }

    // Консуматор
    public Integer consume() throws InterruptedException {
        Integer item = queue.take(); // Блокира, ако опашката е празна
        System.out.println("Consumed: " + item);
        return item;
    }
}

Какво можете да разкажете за многопоточните колекции в Java?