Mercurial > hg > Database > Christie

annotate src/main/java/christie/codegear/StartCodeGear.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 be58bfe90766
children ef5aad739292
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package christie.codegear;
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
2
6
3dcfe63d6394 set type to DataGear by Annotation
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 5
diff changeset
3 import java.util.concurrent.ConcurrentHashMap;
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 import java.util.concurrent.LinkedBlockingQueue;
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 import java.util.concurrent.ThreadPoolExecutor;
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 import java.util.concurrent.TimeUnit;
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
7
7
21372a589bd3 add CodeGearExecutor
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 6
diff changeset
8 public abstract class StartCodeGear extends CodeGear{
29
be58bfe90766 remove synchronized
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
9 static ConcurrentHashMap<Integer, CodeGearManager> cgmList = new ConcurrentHashMap<>();
196
ad49723367c2 add priority
akahori
parents: 29
diff changeset
10 //static LinkedBlockingQueue<Runnable> taskQueue = new LinkedBlockingQueue<Runnable>();
ad49723367c2 add priority
akahori
parents: 29
diff changeset
11 /*static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), // initial number of threads
2
bacdcb5e6dcf change StartCodeGear static
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 1
diff changeset
12 Runtime.getRuntime().availableProcessors(),
bacdcb5e6dcf change StartCodeGear static
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 1
diff changeset
13 Integer.MAX_VALUE, // keepAliveTime
bacdcb5e6dcf change StartCodeGear static
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 1
diff changeset
14 TimeUnit.SECONDS,
196
ad49723367c2 add priority
akahori
parents: 29
diff changeset
15 taskQueue);*/
ad49723367c2 add priority
akahori
parents: 29
diff changeset
16 static ThreadPoolExecutor threadPoolExecutor = PriorityThreadPoolExecutors.createThreadPool(Runtime.getRuntime().availableProcessors(), Integer.MAX_VALUE);
17
59fabebb67d8 delete cgmName as String, add cgmID as int
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 15
diff changeset
17 static int cgmCount = 1;
13
bcd4f2c19185 don't work MessagePack unconvert for remote put
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 8
diff changeset
18
15
4e867538adb7 change DataGearManager to abstract class for delete static dataGears
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
19 public StartCodeGear(CodeGearManager cgm){
4e867538adb7 change DataGearManager to abstract class for delete static dataGears
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
20 cgm.setup(this);
13
bcd4f2c19185 don't work MessagePack unconvert for remote put
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 8
diff changeset
21 }
2
bacdcb5e6dcf change StartCodeGear static
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 1
diff changeset
22
17
59fabebb67d8 delete cgmName as String, add cgmID as int
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 15
diff changeset
23 public static CodeGearManager createCGM(int localPort){
29
be58bfe90766 remove synchronized
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
24 CodeGearManager cgm = new CodeGearManager(cgmCount, threadPoolExecutor, cgmList, localPort);
be58bfe90766 remove synchronized
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
25 cgmList.put(cgmCount++, cgm);
2
bacdcb5e6dcf change StartCodeGear static
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 1
diff changeset
26 return cgm;
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 }
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
28
15
4e867538adb7 change DataGearManager to abstract class for delete static dataGears
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
29 public static CodeGearManager getCGM(String name){
29
be58bfe90766 remove synchronized
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 25
diff changeset
30 return cgmList.get(name);
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 }
5
5be6647b87d2 StartCodeGear implements Runnable to wait InputDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
32
15
4e867538adb7 change DataGearManager to abstract class for delete static dataGears
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
33 @Override
4e867538adb7 change DataGearManager to abstract class for delete static dataGears
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
34 protected void run(CodeGearManager cgm) {}
4e867538adb7 change DataGearManager to abstract class for delete static dataGears
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 13
diff changeset
35
5
5be6647b87d2 StartCodeGear implements Runnable to wait InputDataGear
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
36
1
3ea61d0bfc34 add dependency proccess but not work
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff changeset
37 }