Mercurial > hg > Database > Christie
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() {