update new test case files[beetp]

Chris2018998 · Mar 11, 2024 · fecff97 · fecff97
1 parent 69ce1eb
commit fecff97
Show file tree

Hide file tree

Showing 11 changed files with 19 additions and 19 deletions.
diff --git a/src/test/java/org/stone/beetp/config/PoolConfigCheck.java b/src/test/java/org/stone/beetp/config/PoolConfigCheck.java
@@ -8,7 +8,7 @@
 
 import org.stone.base.TestCase;
 import org.stone.beetp.TaskServiceConfig;
-import org.stone.beetp.exception.TaskServiceConfigException;
+import org.stone.beetp.pool.exception.TaskServiceConfigException;
 
 import java.lang.reflect.Field;
 import java.util.LinkedList;

diff --git a/src/test/java/org/stone/beetp/join/ArraySumJoinOperator.java b/src/test/java/org/stone/beetp/join/ArraySumJoinOperator.java
@@ -51,11 +51,11 @@ public Task<Integer>[] split(Task task) {
     public Integer join(TaskHandle<Integer>[] children) {
         int sum = 0;
         for (TaskHandle<Integer> handle : children) {
-                try {
-                    sum += handle.get();
-                } catch (Exception e) {
-                }
+            try {
+                sum += handle.get();
+            } catch (Exception e) {
             }
+        }
         return sum;
     }
 }
diff --git a/src/test/java/org/stone/beetp/once/GetTimeoutTest.java b/src/test/java/org/stone/beetp/once/GetTimeoutTest.java
@@ -15,7 +15,7 @@
 import org.stone.beetp.TaskHandle;
 import org.stone.beetp.TaskService;
 import org.stone.beetp.TaskServiceConfig;
-import org.stone.beetp.exception.TaskResultGetTimeoutException;
+import org.stone.beetp.pool.exception.TaskResultGetTimeoutException;
 
 import java.util.concurrent.TimeUnit;
 

diff --git a/src/test/java/org/stone/beetp/once/InvokeAllTimeoutTest.java b/src/test/java/org/stone/beetp/once/InvokeAllTimeoutTest.java
@@ -17,8 +17,8 @@
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 
-import static org.stone.beetp.TaskStates.TASK_CALL_EXCEPTION;
 import static org.stone.beetp.TaskStates.TASK_CANCELLED;
+import static org.stone.beetp.TaskStates.TASK_EXEC_EXCEPTION;
 
 public class InvokeAllTimeoutTest extends TestCase {
     public void test() throws Exception {
@@ -38,7 +38,7 @@ public void test() throws Exception {
 
         for (TaskHandle handle : handleList) {
             int state = handle.getState();
-            if (state == TASK_CANCELLED || state == TASK_CALL_EXCEPTION) {
+            if (state == TASK_CANCELLED || state == TASK_EXEC_EXCEPTION) {
                 existException = true;
                 break;
             }

diff --git a/src/test/java/org/stone/beetp/once/InvokeAnyNormalTest.java b/src/test/java/org/stone/beetp/once/InvokeAnyNormalTest.java
@@ -16,7 +16,7 @@
 import java.util.ArrayList;
 import java.util.List;
 
-import static org.stone.beetp.TaskStates.TASK_CALL_EXCEPTION;
+import static org.stone.beetp.TaskStates.TASK_EXEC_EXCEPTION;
 
 public class InvokeAnyNormalTest extends TestCase {
     public void test() throws Exception {
@@ -30,6 +30,6 @@ public void test() throws Exception {
         taskList.add(new ExceptionTask());
         taskList.add(new HelloTask());
         TaskHandle handle = service.invokeAny(taskList);
-        if (handle.getState() == TASK_CALL_EXCEPTION) TestUtil.assertError("InvokeAny test failed");
+        if (handle.getState() == TASK_EXEC_EXCEPTION) TestUtil.assertError("InvokeAny test failed");
     }
 }
diff --git a/src/test/java/org/stone/beetp/once/InvokeAnyTimeoutTest.java b/src/test/java/org/stone/beetp/once/InvokeAnyTimeoutTest.java
@@ -12,7 +12,7 @@
 import org.stone.base.TestCase;
 import org.stone.base.TestUtil;
 import org.stone.beetp.*;
-import org.stone.beetp.exception.TaskResultGetTimeoutException;
+import org.stone.beetp.pool.exception.TaskResultGetTimeoutException;
 
 import java.util.ArrayList;
 import java.util.List;

diff --git a/src/test/java/org/stone/beetp/once/TaskInterruptTest.java b/src/test/java/org/stone/beetp/once/TaskInterruptTest.java
@@ -15,7 +15,7 @@
 import org.stone.beetp.TaskHandle;
 import org.stone.beetp.TaskService;
 import org.stone.beetp.TaskServiceConfig;
-import org.stone.beetp.exception.TaskExecutionException;
+import org.stone.beetp.pool.exception.TaskExecutionException;
 
 /**
  * cancel test

diff --git a/src/test/java/org/stone/beetp/once/TaskRejectTest.java b/src/test/java/org/stone/beetp/once/TaskRejectTest.java
@@ -14,7 +14,7 @@
 import org.stone.beetp.HelloTask;
 import org.stone.beetp.TaskService;
 import org.stone.beetp.TaskServiceConfig;
-import org.stone.beetp.exception.TaskRejectedException;
+import org.stone.beetp.pool.exception.TaskRejectedException;
 
 /**
  * task reject test

diff --git a/src/test/java/org/stone/beetp/performance/mock/TimeMonitorTaskThreadsFactory.java b/src/test/java/org/stone/beetp/performance/mock/TimeMonitorTaskThreadsFactory.java
@@ -2,7 +2,7 @@
 
 public interface TimeMonitorTaskThreadsFactory {
 
-    public TimeMonitorTaskSubmitThread[] create(TimeMonitorTaskPoolInitConfig config);
+    TimeMonitorTaskSubmitThread[] create(TimeMonitorTaskPoolInitConfig config);
 
-    public void shutdownTaskPool();
+    void shutdownTaskPool();
 }
diff --git a/src/test/java/org/stone/beetp/schedlue/OnceTimedTaskCallbackTest.java b/src/test/java/org/stone/beetp/schedlue/OnceTimedTaskCallbackTest.java
@@ -16,7 +16,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.LockSupport;
 
-import static org.stone.beetp.TaskStates.TASK_CALL_RESULT;
+import static org.stone.beetp.TaskStates.TASK_EXEC_RESULT;
 
 /**
  * OnceTimedTaskTest
@@ -37,7 +37,7 @@ public void test() throws Exception {
 
         if (handle.isPeriodic()) TestUtil.assertError("Once Timed Task can't be periodic");
         if (!"Hello".equals(handle.get())) TestUtil.assertError("Once Timed Task test failed");
-        if (handle.getState() != TASK_CALL_RESULT) TestUtil.assertError("Once Timed Task test failed");
+        if (handle.getState() != TASK_EXEC_RESULT) TestUtil.assertError("Once Timed Task test failed");
         if (!callback.beforeInd || !callback.onCallDoneInd) TestUtil.assertError("Call back test Failed");
         if (!"Hello".equals(callback.result)) TestUtil.assertError("Call back test Failed");
     }

diff --git a/src/test/java/org/stone/beetp/schedlue/OnceTimedTaskTest.java b/src/test/java/org/stone/beetp/schedlue/OnceTimedTaskTest.java
@@ -19,7 +19,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.LockSupport;
 
-import static org.stone.beetp.TaskStates.TASK_CALL_RESULT;
+import static org.stone.beetp.TaskStates.TASK_EXEC_RESULT;
 
 /**
  * OnceTimedTaskTest
@@ -39,6 +39,6 @@ public void test() throws Exception {
 
         if (handle.isPeriodic()) TestUtil.assertError("Once Timed Task can't be periodic");
         if (!"Hello".equals(handle.get())) TestUtil.assertError("Once Timed Task test failed");
-        if (handle.getState() != TASK_CALL_RESULT) TestUtil.assertError("Once Timed Task test failed");
+        if (handle.getState() != TASK_EXEC_RESULT) TestUtil.assertError("Once Timed Task test failed");
     }
 }