1

我有一个将值存储为 AtomicInteger 的 Counter 类。该类应该是线程安全的。我有方法boolean consume(int number)应该递减计数器并返回trueif counter >= number，并且不应该更改计数器并返回falseifcounter < number

class Counter {
   AtomicInteger counter = new AtomicInteger(initialValue);

   boolean consume(int number) {
     counter.accumulateAndGet(number, (prev, next) -> {
            if (number <= prev) {
                return prev - number;
            } else {
                // not modify the previous number;
                return prev;
            }
        });
       return ???
   }
}

而且我不知道该功能是否适用。我找到了以下解决方案

boolean consume(int number) {
    AtomicBoolean result = new AtomicBoolean(false);
    counter.accumulateAndGet(number, (prev, next) -> {
            if (number <= prev) {
                result.set(true);
                return prev - number;
                // function applied
            } else {
                result.set(false);
                // not modify the previous number;
                return prev;
            }
    });
    return result.get();
}

accumulateAndGet但是sais的javadoc ：

该函数应该没有副作用，因为当尝试更新由于线程之间的争用而失败时，它可能会被重新应用。

所以，我的解决方案有副作用。使用安全吗？如果没有，我怎样才能得到相同的结果？

4

1 回答 1

0

从描述中，听起来好像你想要这样的东西：

class Counter {
    private final int initialValue = 42; // make compile

    /** Non-negative count. */
    private final AtomicInteger counter = new AtomicInteger(initialValue);

    public boolean consume(int number) {
        for (;;) {
           int old = counter.get();
           int next = old-number;

           if (next >= 0) {
               if (counter.compareAndSet(old, next)) {
                   return true;
               };
           } else {
               return false;
           }
        }
    }
}

因为当尝试更新由于线程之间的争用而失败时，它可能会被重新应用。

问题中的代码可以执行一次或多次，但如果不方便，则使用便捷方法无济于事。

于 2019-12-02T02:09:38.810 回答