tps测试

jwpttcg66 · Apr 20, 2017 · a3558e8 · a3558e8
1 parent 0501b00
commit a3558e8
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 11 deletions.
diff --git a/src/main/java/com/snowcattle/game/excutor/pool/UpdateExecutorService.java b/src/main/java/com/snowcattle/game/excutor/pool/UpdateExecutorService.java
@@ -21,17 +21,10 @@ public class UpdateExecutorService implements IUpdateExcutor{
     private NonOrderedQueuePoolExecutor nonOrderedQueuePoolExecutor;
 
 
-    public UpdateExecutorService(int corePoolSize, long keepAliveTime, TimeUnit unit) {
-//        super(corePoolSize, Integer.MAX_VALUE, keepAliveTime, unit, new LinkedBlockingDeque<Runnable>(),
-//                new ThreadNameFactory(Constants.Thread.UPDATE));
+    public UpdateExecutorService(int corePoolSize) {
         nonOrderedQueuePoolExecutor = new NonOrderedQueuePoolExecutor(corePoolSize);
     }
 
-//    public UpdateExecutorService(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, RejectedExecutionHandler rejectedExecutionHandler) {
-//        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, new LinkedBlockingDeque<Runnable>(),
-//                new ThreadNameFactory(Constants.Thread.UPDATE),rejectedExecutionHandler);
-//    }
-
     @Override
     public void excutorUpdate(DispatchThread dispatchThread, IUpdate iUpdate, boolean firstFlag, int updateExcutorIndex) {
         LockSupportUpdateFuture lockSupportUpdateFuture = new LockSupportUpdateFuture(dispatchThread);

diff --git a/src/test/java/com/snowcattle/game/excutor/update/async/AsyncUpdateBusTest.java b/src/test/java/com/snowcattle/game/excutor/update/async/AsyncUpdateBusTest.java
@@ -33,9 +33,7 @@ public static void testEvent() throws Exception {
 //        int corePoolSize = 100;
         int maxSize = 20000;
         int corePoolSize = 50;
-        long keepAliveTime = 0;
-        TimeUnit timeUnit = TimeUnit.MILLISECONDS;
-        UpdateExecutorService updateExecutorService = new UpdateExecutorService(corePoolSize,  keepAliveTime, timeUnit);
+        UpdateExecutorService updateExecutorService = new UpdateExecutorService(corePoolSize);
         int cycleSleepTime = 1000 / Constants.cycle.cycleSize;
         LockSupportDisptachThread dispatchThread = new LockSupportDisptachThread(updateEventBus, updateExecutorService
                 , cycleSleepTime, cycleSleepTime * 1000000);