Skip to content

Commit

Permalink
+ coco4j version bump
Browse files Browse the repository at this point in the history
  • Loading branch information
q3769 committed May 12, 2024
1 parent 8b391a9 commit 2ca26c2
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@

<groupId>io.github.q3769</groupId>
<artifactId>conottle</artifactId>
<version>12.0.0</version>
<version>12.0.1</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
Expand Down Expand Up @@ -67,7 +67,7 @@
<dependency>
<groupId>io.github.q3769</groupId>
<artifactId>coco4j</artifactId>
<version>9.2.0</version>
<version>10.0.0</version>
</dependency>
<dependency>
<groupId>com.google.code.findbugs</groupId>
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/conottle/Conottle.java
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@

import static org.awaitility.Awaitility.await;

import coco4j.ProtectiveFuture;
import coco4j.DefensiveFuture;
import coco4j.Semaphores;
import coco4j.ThreadFactories;
import elf4j.Logger;
Expand Down Expand Up @@ -86,7 +86,7 @@ private static int requireNonNegativeOrThrow(int value) {
return executor;
});
CompletableFuture<V> taskCompletableFuture = taskCompletableFutureHolder.getCompletableFuture();
Future<V> copy = new ProtectiveFuture<>(taskCompletableFuture);
Future<V> copy = new DefensiveFuture<>(taskCompletableFuture);
taskCompletableFuture.whenCompleteAsync(
(r, e) -> activeThrottlingExecutors.computeIfPresent(clientId, (k, checkedExecutor) -> {
if (checkedExecutor.hasMoreWork()) {
Expand Down

0 comments on commit 2ca26c2

Please sign in to comment.