diff src/main/java/christie/codegear/CodeGearManager.java @ 196:ad49723367c2

add priority
author akahori
date Sat, 09 Mar 2019 14:03:06 +0900
parents e60ee525841d
children ef5aad739292
line wrap: on
line diff
--- a/src/main/java/christie/codegear/CodeGearManager.java	Sat Mar 09 10:19:03 2019 +0900
+++ b/src/main/java/christie/codegear/CodeGearManager.java	Sat Mar 09 14:03:06 2019 +0900
@@ -31,6 +31,8 @@
         this.localPort = localPort;
         daemon = new ChristieDaemon(localPort, this);
         daemon.listen();
+
+
     }
 
     public LocalDataGearManager getLocalDGM(){
@@ -53,11 +55,15 @@
     }
 
     public void submit(CodeGear cg){
-        threadPoolExecutor.execute(cg.getCge());
+        threadPoolExecutor.execute(PriorityThreadPoolExecutors.PriorityRunnable.of(cg.getCge(), cg.getCge().getPriority()));
     }
 
     public void setup(CodeGear cg){
-        cg.setup(this);
+        setup(cg, Thread.NORM_PRIORITY);
+    }
+
+    public void setup(CodeGear cg, int priority){
+        cg.setup(this, priority);
     }
 
     public ConcurrentHashMap<Integer, CodeGearManager> getCgmList() {