Add failing unit test for deadlock issue

Author: henry701

src/test/java/io/lettuce/core/cluster/topology/ClusterTopologyRefreshUnitTests.java

@@ -21,6 +21,7 @@
 
 import static io.lettuce.TestTags.UNIT_TEST;
 import static org.assertj.core.api.Assertions.*;
+import static org.junit.jupiter.api.Timeout.ThreadMode.SEPARATE_THREAD;
 import static org.mockito.ArgumentMatchers.*;
 import static org.mockito.Mockito.*;
 import static org.mockito.Mockito.anyLong;
@@ -40,6 +41,7 @@
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.TimeUnit;
 
+import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
@@ -455,6 +457,20 @@ void shouldCloseConnections() {
         verify(connection2).closeAsync();
     }
 
+    /**
+     * @see <a href="https://github.com/redis/lettuce/issues/3240">Issue link</a>
+     */
+    @Test
+    @org.junit.jupiter.api.Timeout(value = 5, unit = TimeUnit.SECONDS, threadMode = SEPARATE_THREAD)
+    void shouldHandleInvalidUrisWithoutDeadlock() {
+        List<RedisURI> seed = Arrays.asList(RedisURI.create("redis://localhost:$(INVALID_DATA):CONFIG"),
+                RedisURI.create("redis://localhost:$(INVALID_DATA):CONFIG"));
+        CompletionException completionException = Assertions.assertThrows(CompletionException.class,
+                () -> sut.loadViews(seed, Duration.ofSeconds(1), true).toCompletableFuture().join());
+        assertThat(completionException)
+                .hasRootCauseInstanceOf(DefaultClusterTopologyRefresh.CannotRetrieveClusterPartitions.class);
+    }
+
     @Test
     void undiscoveredAdditionalNodesShouldBeLastUsingClientCount() {