v2.0.4

Author: Andrey Kurilov

README.md

@@ -25,7 +25,7 @@ executed concurrently also.
 ## Gradle
 
 ```groovy
-compile group: 'com.github.akurilov', name: 'java-concurrent', version: '2.0.3'
+compile group: 'com.github.akurilov', name: 'java-concurrent', version: '2.0.4'
 ```
 
 ## Implementing Basic Coroutine

build.gradle

@@ -11,7 +11,7 @@ allprojects {
 	apply plugin: "maven"
 	apply plugin: "signing"
 	group = "com.github.akurilov"
-	version = "2.0.3"
+	version = "2.0.4"
 }
 
 ext.moduleName = "${group}.concurrent"

src/main/java/com/github/akurilov/concurrent/AsyncRunnableBase.java

@@ -16,8 +16,9 @@ public abstract class AsyncRunnableBase
 implements AsyncRunnable {
 
 	private volatile State state = State.INITIAL;
+
 	private final Lock stateLock = new ReentrantLock();
-	protected final Condition stateChanged = stateLock.newCondition();
+	private final Condition stateChanged = stateLock.newCondition();
 
 	@Override
 	public final State state() {
@@ -176,18 +177,15 @@ public void close()
 		} catch(final IllegalStateException ignored) {
 		}
 		// then close actually
-		if(stateLock.tryLock()) {
-			try {
-				if(null != state) {
-					doClose();
-					state = null;
-					stateChanged.signalAll();
-				}
-			} finally {
-				stateLock.unlock();
+		stateLock.lock();
+		try {
+			if(null != state) {
+				doClose();
+				state = null;
+				stateChanged.signalAll();
 			}
-		} else {
-			throw new IllegalStateException("Close: failed to acquire the state lock");
+		} finally {
+			stateLock.unlock();
 		}
 	}