Preparing release

Author: vsilaev

README.md

@@ -1,4 +1,4 @@
-[![Maven Central](https://img.shields.io/maven-central/v/net.tascalate.concurrent/net.tascalate.concurrent.lib.svg)](https://search.maven.org/artifact/net.tascalate.concurrent/net.tascalate.concurrent.lib/0.6.6/jar) [![GitHub release](https://img.shields.io/github/release/vsilaev/tascalate-concurrent.svg)](https://github.com/vsilaev/tascalate-concurrent/releases/tag/0.6.6) [![license](https://img.shields.io/github/license/vsilaev/tascalate-concurrent.svg)](http://www.apache.org/licenses/LICENSE-2.0.txt)
+[![Maven Central](https://img.shields.io/maven-central/v/net.tascalate.concurrent/net.tascalate.concurrent.lib.svg)](https://search.maven.org/artifact/net.tascalate.concurrent/net.tascalate.concurrent.lib/0.6.7/jar) [![GitHub release](https://img.shields.io/github/release/vsilaev/tascalate-concurrent.svg)](https://github.com/vsilaev/tascalate-concurrent/releases/tag/0.6.7) [![license](https://img.shields.io/github/license/vsilaev/tascalate-concurrent.svg)](http://www.apache.org/licenses/LICENSE-2.0.txt)
 # tascalate-concurrent
 The library provides an implementation of the CompletionStage interface and related classes these are designed to support long-running blocking tasks (typically, I/O bound) - unlike Java 8 built-in implementation, [CompletableFuture](https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html), that is primarily supports computational tasks.
 # Why a CompletableFuture is not enough?
@@ -13,7 +13,7 @@ Add Maven dependency
 <dependency>
     <groupId>net.tascalate.concurrent</groupId>
     <artifactId>net.tascalate.concurrent.lib</artifactId>
-    <version>0.6.6</version>
+    <version>0.6.7</version>
 </dependency>
 ```
 

pom.xml

@@ -4,7 +4,7 @@
 
 	<groupId>net.tascalate.concurrent</groupId>
 	<artifactId>net.tascalate.concurrent.lib</artifactId>
-	<version>0.6.7-SNAPSHOT</version>
+	<version>0.6.7</version>
 	<packaging>jar</packaging>  
 
 	<name>Tascalate Concurrenct</name>

src/main/java/net/tascalate/concurrent/CompletableSubTask.java

@@ -17,7 +17,7 @@
 
 import java.util.concurrent.Callable;
 import java.util.concurrent.Executor;
-import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicReference;
 
 /**
  * The {@link Promise} implementation for intermediate long-running blocking task
@@ -29,20 +29,19 @@ class CompletableSubTask<T> extends AbstractCompletableTask<T> {
 
     static class DelegatingCallable<T> implements Callable<T> {
 
-        final private AtomicBoolean setupGuard = new AtomicBoolean(false);
-        private Callable<T> delegate;
+        final private AtomicReference<Callable<T>> delegateRef = new AtomicReference<>(null);
 
         void setup(Callable<T> delegate) {
-            if (setupGuard.compareAndSet(false, true)) {
-                this.delegate = delegate;
-            } else {
+            boolean updated = delegateRef.compareAndSet(null, delegate);
+            if (!updated) {
                 throw new IllegalStateException("Delegate may be set only once");
             }
         }
 
         @Override
         public T call() throws Exception {
-            if (!setupGuard.get()) {
+            Callable<T> delegate = delegateRef.get();
+            if (null == delegate) {
                 throw new IllegalStateException("Call is not configured");
             } else {
                 return delegate.call();