Skip to content

Commit

Permalink
For concurrent handling test changed executor from fixed size to cach…
Browse files Browse the repository at this point in the history
…ed thread pool.
  • Loading branch information
SanHalacogluImproving committed Mar 12, 2024
1 parent a497fcf commit 7c6e51d
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ public void send_and_receive_non_ascii_unicode() {
@ParameterizedTest
@ValueSource(ints = {100, 2 ^ 16})
public void client_can_handle_concurrent_workload(int valueSize) {
ExecutorService executorService = Executors.newFixedThreadPool(8);
ExecutorService executorService = Executors.newCachedThreadPool();
RedisClusterClient client =
RedisClusterClient.CreateClient(commonClusterClientConfig().build()).get();
CompletableFuture[] futures = new CompletableFuture[100];
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ public void send_and_receive_non_ascii_unicode() {
@ParameterizedTest
@ValueSource(ints = {100, 2 ^ 16})
public void client_can_handle_concurrent_workload(int valueSize) {
ExecutorService executorService = Executors.newFixedThreadPool(8);
ExecutorService executorService = Executors.newCachedThreadPool();
RedisClient client = RedisClient.CreateClient(commonClientConfig().build()).get();
CompletableFuture[] futures = new CompletableFuture[100];

Expand Down

0 comments on commit 7c6e51d

Please sign in to comment.