Simplified test

Author: rPraml

ebean-datasource/src/test/java/io/ebean/datasource/pool/ConnectionPoolRecoverTest.java

@@ -15,9 +15,6 @@
 
 public class ConnectionPoolRecoverTest {
 
-  private int success;
-  private int failure;
-
   @Test
   void testHeavyLoadPool() throws Exception {
     DataSourcePool pool = DataSourceBuilder.create()
@@ -31,35 +28,16 @@ void testHeavyLoadPool() throws Exception {
       //     .heartbeatMaxPoolExhaustedCount(1)
       .failOnStart(false)
       .build();
-    ExecutorService executorService = Executors.newCachedThreadPool();
     try {
-      List<Future<?>> futures = new ArrayList<>();
-      for (int i = 0; i < 2; i++) {
-        futures.add(executorService.submit(() -> doSomeWork(pool)));
-      }
-
-      for (Future<?> future : futures) {
-        future.get();
+      for (int i = 0; i < 5; i++) {
+        try (Connection conn = pool.getConnection()) {
+          Thread.sleep(2000);
+          conn.rollback();
+        }
       }
-      assertThat(success).isGreaterThan(1);
     } finally {
-      executorService.shutdownNow();
       pool.shutdown();
     }
-
-  }
-
-  private void doSomeWork(DataSourcePool pool) {
-    for (int i = 0; i < 20; i++) {
-      System.out.println("Success: " + success + " failure: " + failure);
-      try (Connection conn = pool.getConnection()) {
-        Thread.sleep(2000);
-        success++;
-      } catch (Exception e) {
-        // nop
-        failure++;
-      }
-    }
   }
 
 }