+ moved pending task count increment part of async supply instead of separate blocking step

Author: q3769

pom.xml

@@ -30,7 +30,7 @@
 
     <groupId>io.github.q3769</groupId>
     <artifactId>conottle</artifactId>
-    <version>11.0.2</version>
+    <version>11.0.3</version>
     <packaging>jar</packaging>
     <name>conottle</name>
     <description>A Java concurrent API to throttle the maximum concurrency to process tasks for any given client while

src/main/java/conottle/PendingTaskCountingThrottleExecutor.java

@@ -33,7 +33,7 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
-import static coco4j.CocoUtils.supplyByUnchecked;
+import static coco4j.CocoUtils.callUnchecked;
 
 /**
  * Not thread safe: Any and all non-private methods always should be externally synchronized while multithreading.
@@ -74,8 +74,10 @@ public boolean noPendingWorkAfterTaskComplete() {
     @Override
     @NonNull
     public <V> CompletableFuture<V> submit(Callable<V> task) {
-        pendingTaskCount++;
-        return CompletableFuture.supplyAsync(supplyByUnchecked(task), taskThreadPool);
+        return CompletableFuture.supplyAsync(() -> {
+            pendingTaskCount++;
+            return callUnchecked(task);
+        }, taskThreadPool);
     }
 
     @Override

src/main/java/conottle/PooledExecutorFactory.java

@@ -31,17 +31,17 @@
 import org.apache.commons.pool2.impl.DefaultPooledObject;
 
 /**
- * Creates pooled {@link PendingTaskCountingThrottleExecutor} instances that provide throttled async client task executions.
- * Each {@code PendingTaskCountingThrottleExecutor} instance throttles its client task concurrency at the max capacity of the
- * executor's backing thread pool.
+ * Creates pooled {@link PendingWorkAwareExecutor} instances that provide throttled async client task executions. Each
+ * {@code PendingWorkAwareExecutor} instance throttles its client task concurrency
  */
 final class PooledExecutorFactory extends BasePooledObjectFactory<PendingWorkAwareExecutor> {
 
     private final int maxExecutorConcurrency;
 
     /**
      * @param maxExecutorConcurrency
-     *         max concurrent threads of the {@link PendingTaskCountingThrottleExecutor} instance produced by this factory
+     *         max concurrent tasks that can be in execution of the {@link PendingWorkAwareExecutor} instance produced
+     *         by this factory
      */
     PooledExecutorFactory(int maxExecutorConcurrency) {
         this.maxExecutorConcurrency = maxExecutorConcurrency;
@@ -60,8 +60,8 @@ public PooledObject<PendingWorkAwareExecutor> wrap(PendingWorkAwareExecutor thro
     }
 
     @Override
-    public void destroyObject(PooledObject<PendingWorkAwareExecutor> pooledThrottlingExecutor,
-            DestroyMode destroyMode) throws Exception {
+    public void destroyObject(PooledObject<PendingWorkAwareExecutor> pooledThrottlingExecutor, DestroyMode destroyMode)
+            throws Exception {
         try {
             super.destroyObject(pooledThrottlingExecutor, destroyMode);
         } finally {