Atomic. Java - jf17.ru

Atomic :

Package java.util.concurrent.atomic.* ;
Операция называется атомарной тогда, когда её можно безопасно выполнять при параллельных вычислениях в нескольких потоках, не используя при этом ни блокировок, ни synchronized .
Внутри атомарные классы очень активно используют сравнение с обменом (compare-and-swap, CAS), атомарную инструкцию, которую поддерживает большинство современных процессоров

AtomicInteger :

внутри private volatile int value;

int *. incrementAndGet() : корректно увеличить число
int *. decrementAndGet() : корректно уменьшить число
int *. get() : получить значение
void *. set(int newValue) : задать новое значение
int *. updateAndGet(IntUnaryOperator updateFunction) : принимает в качестве аргумента лямбда-выражение и выполняет над числом заданные арифметические операции
int *. accumulateAndGet(int x, IntBinaryOperator accumulatorFunction) : принимает лямбда-выражения типа IntBinaryOperator

LongAdder :

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

*. increment() :
*. add() :
*. sum() :
*. sumThenReset() :

LongAccumulator :

Класс LongAccumulator несколько расширяет возможности LongAdder
Вместо простого сложения он обрабатывает входящие значения с помощью лямбды типа LongBinaryOperator, которая передаётся при инициализации. .

пример :


public class BadAtomic {

      private static int value;
//    private static AtomicInteger value = new AtomicInteger(0) ;

    public static void main(String[] args) {

        for (int i = 0; i < 10_000; i++) {
            new MyThread().start();
        }
        try {
            Thread.sleep(2_048);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(value);

    }

    private static class MyThread extends Thread {
        @Override
        public void run() {
            value++;
//          value.incrementAndGet();
        }
    }
}

Полезные ссылки:

Package java.util.concurrent.atomic JavaDoc (Java 8)
Package java.util.concurrent.atomic JavaDoc (Java 7)
unsafe.cpp Unsafe_CompareAndSwapInt

Главная