Allow the ScheduledExecutorService to be provided by the container (#178

)

Signed-off-by: Tom Evans <tevans@uk.ibm.com>
Co-authored-by: Emily Jiang <emijiang6@googlemail.com>

.gitignore

@@ -19,3 +19,4 @@ release.conf
 .~lock.*.odg#
 **.DS_Store
 .vscode
+

tck/src/main/java/org/eclipse/microprofile/reactive/streams/operators/tck/ReactiveStreamsTck.java

@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (c) 2018, 2022 Contributors to the Eclipse Foundation
+ * Copyright (c) 2018, 2023 Contributors to the Eclipse Foundation
  *
  * See the NOTICE file(s) distributed with this work for additional
  * information regarding copyright ownership.
@@ -86,14 +86,30 @@ public void shutdownEngine() {
         if (engine != null) {
             shutdownEngine(engine);
         }
+        if (executorService != null) {
+            shutdownExecutorService(executorService);
+        }
+    }
+
+    /**
+     * Override this to provide a different ScheduledExecutorService
+     */
+    protected ScheduledExecutorService createExecutorService() {
+        return Executors.newScheduledThreadPool(4);
+    }
+
+    /**
+     * Override this to customize the shutdown of a ScheduledExecutorService
+     */
+    protected void shutdownExecutorService(ScheduledExecutorService executorService) {
         executorService.shutdown();
     }
 
     @Factory
     public Object[] allTests() {
         engine = createEngine();
         rs = createFactory();
-        executorService = Executors.newScheduledThreadPool(4);
+        executorService = createExecutorService();
 
         ReactiveStreamsApiVerification apiVerification = new ReactiveStreamsApiVerification(rs);
         ReactiveStreamsSpiVerification spiVerification =