Модульное приращение с атомными классами Java

Question

Я был удивлен тем, что классы Java AtomicInteger и AtomicLong не имеют методов модульных приращений (так что значение обнуляется до нуля после достижения предела).

Я полагаю, что мне не хватает чего-то очевидного. Каков наилучший способ сделать это?

Например, я хочу поделиться простым Int между потоками, и я хочу, чтобы каждый поток, чтобы иметь возможность увеличить его, скажем, по модулю 10.

я могу создать класс, который использует синхронизацию/блокировку, но есть ли лучший, более простой способ?

Answer 1

Что не так сложно добавить модификатор или блок synchronized к вашему методу addModular()?

Причина, почему Atomic классы не имеют эту функцию является то, что они основаны на specific atomic hardware instructions предлагаемых текущих процессоры, и модульная арифметика не может быть реализована теми, не прибегая к фиксации или другим более сложным и потенциально неэффективным алгоритмам, таким как предложенный матом.

Answer 2

Только мод 10 значение, когда вы читаете его?

public class AtomicWrappingCounter { 
    private final AtomicLong counter = new AtomicLong(); 
    private final int max; 

    public AtomicWrappingCounter(int max) { 
    this.max = max; 
    } 

    public int get() { 
    return (int) (counter.get() % max); 
    } 

    public int incrementAndGet() { 
    return (int) (counter.incrementAndGet() % max); 
    } 
} 

Очевидно, что если вы можете увеличивать этот счетчик более Long.MAX_VALUE раз, вы не могли бы использовать этот подход, но 9 нониллиона много раз, чтобы быть приращения (около 292 лет при ставке 1 наносекунды!).

Answer 3

Я думаю, самый простой способ заключается в создании оберточной счетчик себя, который хранит его значения в AtomicInteger, что-то вроде

public class AtomicWrappingCounter { 
    private AtomicInteger value; 
    private final int max; 

    public AtomicWrappingCounter(int start, int max) { 
     this.value = new AtomicInteger(start); 
     this.max = max; 
    } 

    public int get() { 
     return value.get(); 
    } 

    /* Simple modification of AtomicInteger.incrementAndGet() */ 
    public int incrementAndGet() { 
     for (;;) { 
      int current = get(); 
      int next = (current + 1) % max; 
      if (value.compareAndSet(current, next)) 
       return next; 
     } 
    } 
} 

Почему не AtomicInteger давать что-то вроде этого сам? Кто знает, но я думаю, что намерение авторов параллельной структуры было предоставить некоторые строительные блоки, которые вы могли бы использовать, чтобы лучше создавать свои собственные функции более высокого уровня.

Answer 4

Я был удивлен тем, что классы Java AtomicInteger и AtomicLong не имеют методов для модульных приращений.

Не удивляйтесь, когда стандартный класс не включает в себя «колокола и свистки» для поддержки всех видов необычных прецедентов. Дизайнеры должны рисовать линию где-то на том, что они включают, и что они не включают. Тенденция заключается в поддержке общих случаев использования и случаев использования, которые не могут поддерживаться каким-либо другим способом. В этом случае ни один из этих критериев не применяется.