Я был удивлен, что классы Java AtomicInteger и AtomicLong не имеют методов для модульных приращений (так что значение обнуляется после достижения предела).
Я полагаю, что должен упустить что-то очевидное. Как лучше всего это сделать?
Например, я хочу разделить простой int между потоками, и я хочу, чтобы каждый поток мог увеличивать его, скажем, на мод 10.
Я могу создать класс, использующий синхронизацию/блокировку, но есть ли лучший и более простой способ?
Что сложного в добавлении модификатора synchronized или блока к вашему методу addModular()?
Причина, по которой классы Atomic не имеют этой функциональности, заключается в том, что они основаны на специфических атомарных аппаратные инструкции, предлагаемые современными ЦП, и модульная арифметика не могут быть реализованы без использования блокировки или других более сложных и потенциально неэффективных алгоритмов, таких как предложенный Мэттом.
Просто мод 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);
}
}
Очевидно, что если вы можете увеличить этот счетчик более чем в 2_ раза, вы не сможете использовать этот подход, но 9 квинтиллионов — это много раз для увеличения (около 292 лет со скоростью 1 в наносекунду!).
AtomicLong гарантирует, что после вызова incrementAndGet() другой поток, вызывающий get(), увидит новое значение. Оба потока затем вычисляют значение по модулю самостоятельно, и каждый видит ожидаемый окончательный результат.
- person ColinD; 24.10.2016
В Java 8 вы можете использовать getAndUpdate (и updateAndGet) в AtomicInteger.
Например, если мы хотим иметь счетчик, который обнуляется каждый раз, когда он достигает 10.
AtomicInteger counter = new AtomicInteger(0);
// to get & update
counter.getAndUpdate(value -> (value + 1) % 10)
Я думаю, что самый простой способ - создать счетчик обертывания самостоятельно, который хранит свои значения в 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 сам не предоставляет что-то подобное? Кто знает, но я думаю, что намерение авторов среды параллелизма состояло в том, чтобы предоставить некоторые строительные блоки, которые вы могли бы использовать для лучшего создания своих собственных функций более высокого уровня.
get и compareAndSet в фреймворке. Все остальные методы могут быть построены на них.
- person finnw; 27.01.2011
compareAndSet() не удастся, и вам придется повторить попытку. Если конкуренция очень высока, все потоки будут тратить большую часть своего времени на повторное выполнение цикла. Это отличается от самого compareAndSet(), который (на поддерживающем его оборудовании) реализуется фактически атомарными инструкциями ЦП.
- person Michael Borgwardt; 27.01.2011
incrementAndGet() реализован так же, как его метод здесь, за исключением того, что без мода.
- person ColinD; 27.01.2011
start будет вне [0, max) или если max будет неположительным. value должно быть final. / Также compareAndSet следует вызывать на value, и очень странно иметь cas-loop с таким возвратом вместо do-while.
- person Tom Hawtin - tackline; 17.03.2011
incrementAndGet() в моем образце точно такой же, как реализация AtomicInteger в Sun JDK с небольшой модификацией. Цикл cas с возвратом напрямую взят из кода Sun. Что касается проверки параметров, переданных конструктору, это всего лишь пример кода, а правильная проверка/утверждение инвариантов — это упражнение, которое лучше оставить читателю.
- person matt b; 17.03.2011
Я был удивлен, что классы Java AtomicInteger и AtomicLong не имеют методов для модульных приращений.
Не удивляйтесь, если стандартный класс не включает «прибамбасы» для поддержки всевозможных необычных вариантов использования. Дизайнеры должны провести черту между тем, что они включают, а что нет. Тенденция состоит в том, чтобы поддерживать общие варианты использования и варианты использования, которые невозможно поддерживать каким-либо другим способом. В данном случае ни один из этих критериев не применим.
