Reduce test concurrency based on number of available processors

Author: Michael-A-McMahon

src/test/java/oracle/r2dbc/impl/OracleStatementImplTest.java

@@ -2302,7 +2302,8 @@ private void verifyConcurrentExecute(Connection connection) {
 
     // Create many statements and execute them in parallel.
     @SuppressWarnings({"unchecked","rawtypes"})
-    Publisher<Integer>[] publishers = new Publisher[8];
+    Publisher<Integer>[] publishers =
+      new Publisher[Runtime.getRuntime().availableProcessors() * 4];
 
     for (int i = 0; i < publishers.length; i++) {
       Flux<Integer> flux = Flux.from(connection.createStatement(
@@ -2334,7 +2335,8 @@ private void verifyConcurrentFetch(Connection connection) {
 
       // Create many statements and execute them in parallel.
       @SuppressWarnings({"unchecked","rawtypes"})
-      Publisher<Long>[] publishers = new Publisher[8];
+      Publisher<Long>[] publishers =
+        new Publisher[Runtime.getRuntime().availableProcessors() * 4];
 
       for (int i = 0; i < publishers.length; i++) {