Move blocking random key generation to executor thread

Author: Arooba-git

redis/reactive/src/test/java/example/springdata/redis/commands/KeyCommandsTests.java

@@ -24,6 +24,8 @@
 import java.time.Duration;
 import java.util.Collections;
 import java.util.UUID;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -42,13 +44,15 @@
  * {@link ReactiveRedisConnectionFactory}.
  *
  * @author Mark Paluch
+ * @author Arooba Shahoor
  */
 @SpringBootTest(classes = RedisTestConfiguration.class)
 @EnabledOnRedisAvailable
 class KeyCommandsTests {
 
 	private static final String PREFIX = KeyCommandsTests.class.getSimpleName();
 	private static final String KEY_PATTERN = PREFIX + "*";
+	private final ExecutorService executor = Executors.newSingleThreadExecutor();
 
 	@Autowired ReactiveRedisConnectionFactory connectionFactory;
 
@@ -103,13 +107,15 @@ void storeToListAndPop() {
 
 	private void generateRandomKeys(int nrKeys) {
 
-		var keyFlux = Flux.range(0, nrKeys).map(i -> (PREFIX + "-" + i));
+		executor.execute(() -> {
+			var keyFlux = Flux.range(0, nrKeys).map(i -> (PREFIX + "-" + i));
 
-		var generator = keyFlux.map(String::getBytes).map(ByteBuffer::wrap) //
-				.map(key -> SetCommand.set(key) //
-						.value(ByteBuffer.wrap(UUID.randomUUID().toString().getBytes())));
+			var generator = keyFlux.map(String::getBytes).map(ByteBuffer::wrap) //
+					.map(key -> SetCommand.set(key) //
+							.value(ByteBuffer.wrap(UUID.randomUUID().toString().getBytes())));
 
-		StepVerifier.create(connection.stringCommands().set(generator)).expectNextCount(nrKeys).verifyComplete();
+			StepVerifier.create(connection.stringCommands().set(generator)).expectNextCount(nrKeys).verifyComplete();
+		});
 
 	}