@Override
public void close() {
- final int wasClosed = UPDATER.getAndSet(this, 1);
- Preconditions.checkState(wasClosed == 0, "Transaction factory was already closed");
+ final boolean success = UPDATER.compareAndSet(this, 0, 1);
+ Preconditions.checkState(success, "Transaction factory was already closed");
}
-
}
+