Почему результат меняется при Atomic операциях?

Question

[Артем Абрагмад]

Почему колебается результат на 1 единицу при использовании атомарности?
55251 или 55252

package src;

import java.util.concurrent.atomic.AtomicInteger;

public class Lucky {
    static AtomicInteger x = new AtomicInteger(0);
    static AtomicInteger count = new AtomicInteger(0);

    static class LuckyThread extends Thread {
        @Override
        public void run() {
            while (x.get() < 999999) {
                int i  = x.incrementAndGet();
                if ((i % 10) + (i / 10) % 10 + (i / 100) % 10 == (i / 1000)
                        % 10 + (i / 10000) % 10 + (i / 100000) % 10) {
                    System.out.println(x);
                    count.incrementAndGet();
                }
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {
        Thread t1 = new LuckyThread();
        Thread t2 = new LuckyThread();
        Thread t3 = new LuckyThread();
        t1.start();
        t2.start();
        t3.start();
        t1.join();
        t2.join();
        t3.join();
        System.out.println("Total: " + count);
    }
}

P.S при синхронизации вроде бы проблем нет

Comments

[mayton2019]

Что это за ужасная чепуха?

if ((i % 10) + (i / 10) % 10 + (i / 100) % 10 == (i / 1000)
                        % 10 + (i / 10000) % 10 + (i / 100000) % 10) {

Я тоже вставлял в циклы трекинг статуса но мне хватало битовой маски над числом.

Не обижайся что я делаю такой code-review просто мимо проходя. Но уж просто невозможно глаз оторвать.
Ишешь перфекционизма в одном но как-то поваливаешся совсем в другое.

[Шам]

mayton2019, поясни свои слова. Что такое "трекинг статуса", и о какой битовой маске идёт речь? Предложи свой способ сравнения сумм цифр левых и правых разрядов числа. Как это можно сделать с помощью битовых масок? Опиши способ, которым ты пользовался, или дай ссылку.

Answer 1

[Dmitry Roo]

Вот тут ошибка: while (x.get() < 999999)
Вполне атомарно можно получить тут true на неограниченное количество потоков.

Comments

[Шам]

Можно подробнее объяснить, в чём была проблема и что означает ваш ответ?

[Dmitry Roo]

Шам, добавить нечего

[Шам]

Dmitry Roo, использование x.get() + x.incrementAndGet() там не атомарная операция, отсюда видимо проблемы. Можно ограничиться (i = x.getAndIncrement()) < 999999 в условии цикла. Ну и выводить i в println(), а не x, которую может изменить другой поток. Я прав?

[Dmitry Roo]

Шам, все так.