lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

RestSleepTest

Browse Source
This commit is contained in:
redkale
2024-06-05 16:51:33 +08:00
parent c1992434d0
commit 7d84c0ca1f
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/test/java/org/redkale/test/http/RestSleepTest.java
View File

@@ -6,6 +6,7 @@
package org.redkale.test.http; package org.redkale.test.http;
import java.io.*; import java.io.*;
import java.lang.reflect.Method;
import java.net.*; import java.net.*;
import org.junit.jupiter.api.*; import org.junit.jupiter.api.*;
import org.redkale.boot.Application; import org.redkale.boot.Application;
@@ -20,11 +21,8 @@ import org.redkale.util.*;
/** @author zhangjx */ /** @author zhangjx */
public class RestSleepTest { public class RestSleepTest {
private boolean main;
public static void main(String[] args) throws Throwable { public static void main(String[] args) throws Throwable {
RestSleepTest test = new RestSleepTest(); RestSleepTest test = new RestSleepTest();
test.main = true;
test.run(); test.run();
} }
@@ -37,6 +35,9 @@ public class RestSleepTest {
final ResourceFactory resFactory = ResourceFactory.create(); final ResourceFactory resFactory = ResourceFactory.create();
resFactory.register(JsonConvert.root()); resFactory.register(JsonConvert.root());
resFactory.register(BsonConvert.root()); resFactory.register(BsonConvert.root());
Method method = Application.class.getDeclaredMethod("initWorkExecutor");
method.setAccessible(true);
method.invoke(application);
// ------------------------ 初始化 CService ------------------------------------ // ------------------------ 初始化 CService ------------------------------------
RestSleepService service = Sncp.createSimpleLocalService(RestSleepService.class, resFactory); RestSleepService service = Sncp.createSimpleLocalService(RestSleepService.class, resFactory);
@@ -69,7 +70,6 @@ public class RestSleepTest {
System.out.println("返回结果: " + new String(bytes, 0, pos)); System.out.println("返回结果: " + new String(bytes, 0, pos));
System.out.println("耗时: " + e + " ms"); System.out.println("耗时: " + e + " ms");
server.shutdown(); server.shutdown();
int exptime = Runtime.getRuntime().availableProcessors() > 2 ? 600 : 1100; Assertions.assertTrue(e < 600);
Assertions.assertTrue(e < exptime);
} }
} }