Mercurial > hg > Database > Christie

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

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add priority
author akahori
date Sat, 09 Mar 2019 14:03:06 +0900
parents e60ee525841d
children ef5aad739292
comparison
equal deleted inserted replaced
195:a0be7c83fff8 196:ad49723367c2
29 threadPoolExecutor = exe; 29 threadPoolExecutor = exe;
30 this.cgmID = cgmID; 30 this.cgmID = cgmID;
31 this.localPort = localPort; 31 this.localPort = localPort;
32 daemon = new ChristieDaemon(localPort, this); 32 daemon = new ChristieDaemon(localPort, this);
33 daemon.listen(); 33 daemon.listen();
34
35
34 } 36 }
35 37
36 public LocalDataGearManager getLocalDGM(){ 38 public LocalDataGearManager getLocalDGM(){
37 return localDGM; 39 return localDGM;
38 } 40 }
51 53
52 return remote; 54 return remote;
53 } 55 }
54 56
55 public void submit(CodeGear cg){ 57 public void submit(CodeGear cg){
56 threadPoolExecutor.execute(cg.getCge()); 58 threadPoolExecutor.execute(PriorityThreadPoolExecutors.PriorityRunnable.of(cg.getCge(), cg.getCge().getPriority()));
57 } 59 }
58 60
59 public void setup(CodeGear cg){ 61 public void setup(CodeGear cg){
60 cg.setup(this); 62 setup(cg, Thread.NORM_PRIORITY);
63 }
64
65 public void setup(CodeGear cg, int priority){
66 cg.setup(this, priority);
61 } 67 }
62 68
63 public ConcurrentHashMap<Integer, CodeGearManager> getCgmList() { 69 public ConcurrentHashMap<Integer, CodeGearManager> getCgmList() {
64 return cgmList; 70 return cgmList;
65 } 71 }