UsagesCounter implementation on java

build.gradle.kts

@@ -38,6 +38,7 @@ xomrk {
 			compilations.configureEach {
 				compileJavaTaskProvider?.configure {
 					targetCompatibility = "1.8"
+					sourceCompatibility = "1.8"
 				}
 				compileTaskProvider.configure {
 					compilerOptions {

src/commonMain/kotlin/ru/landgrafhomyak/utility/closeable_state_1/CloseableState.kt

@@ -1,10 +1,10 @@
 package ru.landgrafhomyak.utility.closeable_state_1
 
 public interface CloseableState {
-	public fun assertNotClosed()
-
 	public val isClosed: Boolean
 
+	public fun assertNotClosed()
+
 	@ManualStateManipulation
 	public fun startUsage()
 

src/jvmMain/java/ru/landgrafhomyak/utility/closeable_state_1/jUsagesCounter.java

@@ -0,0 +1,66 @@
+package ru.landgrafhomyak.utility.closeable_state_1;
+
+import ru.landgrafhomyak.utility.closeable_state_1.internal.Misc;
+
+import java.util.concurrent.atomic.AtomicLong;
+
+public class jUsagesCounter extends jUsagesCounter$Errors implements CloseableState.AllowsConcurrency {
+	private final AtomicLong _referencesCounter;
+
+	public jUsagesCounter() {
+		this._referencesCounter = new AtomicLong(0);
+	}
+
+	@Override
+	public boolean isClosed() {
+		return this._referencesCounter.get() < 0;
+	}
+
+	@Override
+	public void assertNotClosed() {
+		if (this._referencesCounter.get() < 0)
+			this.throwClosed();
+	}
+
+	@Override
+	public void startUsage() {
+		while (true) {
+			final long cur = this._referencesCounter.get();
+			if (cur < 0) {
+				this.throwClosed();
+				return;
+			}
+
+			if (this._referencesCounter.compareAndSet(cur, cur + 1))
+				return;
+		}
+	}
+
+	@Override
+	public void finishUsage() {
+		while (true) {
+			final long cur = this._referencesCounter.get();
+			if (cur < 0) {
+				this.throwClosed();
+				return;
+			}
+
+			if (this._referencesCounter.compareAndSet(cur, cur - 1))
+				return;
+		}
+	}
+
+	@Override
+	public void close() {
+		long currentReferencesCount;
+		while (true) {
+			currentReferencesCount = this._referencesCounter.get();
+			if (currentReferencesCount != 0) break;
+			if (this._referencesCounter.compareAndSet(currentReferencesCount, Misc.CLOSED_STATE_VALUE))
+				break;
+		}
+
+		if (currentReferencesCount > 0) this.throwInUse();
+		if (currentReferencesCount < 0) this.throwClosed();
+	}
+}

src/jvmMain/kotlin/ru/landgrafhomyak/utility/closeable_state_1/jUsagesCounter$Errors.kt

@@ -0,0 +1,13 @@
+package ru.landgrafhomyak.utility.closeable_state_1
+
+import kotlin.IllegalStateException
+
+internal abstract class `jUsagesCounter$Errors` {
+	protected open fun throwClosed(): Nothing {
+		throw IllegalStateException("Object is closed")
+	}
+
+	protected open fun throwInUse(): Nothing {
+		throw IllegalStateException("Failed close object because it is in use")
+	}
+}