增加外部通知notify

jwpttcg66 · Mar 28, 2017 · d7fd7a0 · d7fd7a0
1 parent b6f6e1e
commit d7fd7a0
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 16 deletions.
diff --git a/src/main/java/com/snowcattle/game/excutor/thread/LockSupportDisptachThread.java b/src/main/java/com/snowcattle/game/excutor/thread/LockSupportDisptachThread.java
@@ -41,9 +41,8 @@ private void singleCycle(boolean sleepFlag){
         long time = System.nanoTime();
         int cycleSize = getEventBus().getEventsSize();
         int size = getEventBus().cycle(cycleSize);
-        park();
-
         if(sleepFlag) {
+            park();
             long notifyTime = System.nanoTime();
             long diff = (int) (notifyTime - time);
             if (diff < minCycleTime && diff > 0) {

diff --git a/src/test/java/com/snowcattle/game/excutor/event/asyncevent/AsyncNotifyEventTest.java b/src/test/java/com/snowcattle/game/excutor/event/asyncevent/AsyncNotifyEventTest.java
@@ -15,6 +15,7 @@
 import java.util.Timer;
 import java.util.TimerTask;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.LockSupport;
 
 /**
  * Created by jwp on 2017/3/28.
@@ -28,7 +29,7 @@ public static void testEvent() throws Exception {
         EventBus updateEventBus = new EventBus();
 //        int maxSize = 10000;
 //        int corePoolSize = 100;
-        int maxSize = 20;
+        int maxSize = 2;
         int corePoolSize = 2;
         long keepAliveTime = 60;
         TimeUnit timeUnit = TimeUnit.SECONDS;
@@ -43,27 +44,31 @@ public static void testEvent() throws Exception {
         updateEventBus.addEventListener(new DispatchFinishEventListener(dispatchThread, updateService));
 
         updateService.notifyStart();
+//        while (true) {
+//            Thread.currentThread().sleep(100);
+//            LockSupport.unpark(dispatchThread);
+//
+//            LockSupport.park(dispatchThread);
+//            updateService.notifyRun();
+//            break;
+//        }
+
+
         for (long i = 0; i < maxSize; i++) {
             IntegerUpdate integerUpdate = new IntegerUpdate(i);
             EventParam<IntegerUpdate> param = new EventParam<IntegerUpdate>(integerUpdate);
             CycleEvent cycleEvent = new CycleEvent(Constants.EventTypeConstans.readyCreateEventType, integerUpdate.getId(), param);
             updateService.addReadyCreateEvent(cycleEvent);
         }
 
-        while (true){
-            Thread.currentThread().sleep(1000);
-            dispatchThread.unpark();
-            updateService.notifyRun();
-        }
-//        updateService.shutDown();
-//        Timer timer = new Timer();
-//
-//        timer.schedule(new NotifyTask(updateService), 0, 1);
-//        while (true) {
-//            Thread.currentThread().sleep(100);
-//            updateService.toString();
-//        }
 
+//        updateService.shutDown();
+        Timer timer = new Timer();
+        timer.schedule(new NotifyTask(updateService), 0, 10);
+        while (true) {
+            Thread.currentThread().sleep(100);
+            updateService.toString();
+        }
     }
 }