[shardingsphere] branch master updated: Refactor ParallelRunnerScheduler (#22600)

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 4d20217f6d8 Refactor ParallelRunnerScheduler (#22600)
4d20217f6d8 is described below

commit 4d20217f6d8b42e34473c07710d31259bfca8793
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Fri Dec 2 20:28:48 2022 +0800

    Refactor ParallelRunnerScheduler (#22600)
---
 .../test/runner/scheduler/ParallelRunnerScheduler.java            | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/test/runner/src/main/java/org/apache/shardingsphere/test/runner/scheduler/ParallelRunnerScheduler.java b/test/runner/src/main/java/org/apache/shardingsphere/test/runner/scheduler/ParallelRunnerScheduler.java
index 176b5ead027..5e0bec5d671 100644
--- a/test/runner/src/main/java/org/apache/shardingsphere/test/runner/scheduler/ParallelRunnerScheduler.java
+++ b/test/runner/src/main/java/org/apache/shardingsphere/test/runner/scheduler/ParallelRunnerScheduler.java
@@ -17,7 +17,6 @@
 
 package org.apache.shardingsphere.test.runner.scheduler;
 
-import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import org.apache.shardingsphere.test.runner.ParallelRunningStrategy.ParallelLevel;
 import org.apache.shardingsphere.test.runner.executor.ParallelRunnerExecutors;
@@ -31,22 +30,21 @@ import org.junit.runners.model.RunnerScheduler;
  * Parallel runner scheduler.
  */
 @RequiredArgsConstructor
-@Getter
 public final class ParallelRunnerScheduler implements RunnerScheduler {
     
     private final ParallelLevel parallelLevel;
     
-    private final ParallelRunnerExecutors runnerExecutors;
+    private final ParallelRunnerExecutors executors;
     
     @Override
     public void schedule(final Runnable childStatement) {
         ParameterizedArray parameterizedArray = new RunnerParameters(childStatement).getParameterizedArray();
         TestKeyProvider provider = TestKeyProviderFactory.newInstance(parallelLevel);
-        runnerExecutors.getExecutor(parameterizedArray.getDatabaseType()).execute(provider.getKey(parameterizedArray), childStatement);
+        executors.getExecutor(parameterizedArray.getDatabaseType()).execute(provider.getKey(parameterizedArray), childStatement);
     }
     
     @Override
     public void finished() {
-        runnerExecutors.finishAll();
+        executors.finishAll();
     }
 }