Mercurial > hg > Members > tatsuki > Alice

annotate src/alice/codesegment/CodeSegmentManager.java @ 176:4658bf530834 working

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove ant warning
author e095732
date Tue, 29 Jan 2013 10:30:41 +0900
parents a3a2605e16a2
children 481dab56c3dc
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
1 package alice.codesegment;
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
2
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
3 import java.util.concurrent.LinkedBlockingQueue;
21
145667a554ad run CodeSegment with ThreadPoolExecutor
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
4 import java.util.concurrent.ThreadPoolExecutor;
145667a554ad run CodeSegment with ThreadPoolExecutor
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
5 import java.util.concurrent.TimeUnit;
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
6
39
3155337e754e add logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 21
diff changeset
7 import org.apache.log4j.Logger;
3155337e754e add logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 21
diff changeset
8
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
9 public class CodeSegmentManager {
44
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 39
diff changeset
10
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
11 private static CodeSegmentManager instance = new CodeSegmentManager();
8
78b415d019de Local DS and CS work! maybe...
one
parents: 7
diff changeset
12 public LinkedBlockingQueue<CodeSegment> readyQueue = new LinkedBlockingQueue<CodeSegment>();
70
f2d4a4686036 delete CodeSegment receive thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
13 private ThreadPoolExecutor codeSegmentExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), // initial number of threads
21
145667a554ad run CodeSegment with ThreadPoolExecutor
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
14 Runtime.getRuntime().availableProcessors(),
58
ebdcab7b9b04 add comment
one
parents: 57
diff changeset
15 Integer.MAX_VALUE, // keepAliveTime
21
145667a554ad run CodeSegment with ThreadPoolExecutor
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
16 TimeUnit.SECONDS,
145667a554ad run CodeSegment with ThreadPoolExecutor
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
17 new LinkedBlockingQueue<Runnable>());
71
a3a2605e16a2 change checking debug mode of logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 70
diff changeset
18 private Logger logger = Logger.getLogger(CodeSegmentManager.class);
70
f2d4a4686036 delete CodeSegment receive thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
19
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
20 public static CodeSegmentManager get() {
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
21 return instance;
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
22 }
57
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
23
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
24 public static void submit(CodeSegment cs) {
70
f2d4a4686036 delete CodeSegment receive thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
25 CodeSegmentManager csManager = CodeSegmentManager.get();
f2d4a4686036 delete CodeSegment receive thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
26 csManager.codeSegmentExecutor.execute(cs);
71
a3a2605e16a2 change checking debug mode of logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 70
diff changeset
27 if (csManager.logger.isDebugEnabled()) {
a3a2605e16a2 change checking debug mode of logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 70
diff changeset
28 csManager.logger.debug(cs.getClass().getName());
57
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
29 }
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
30 }
44
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 39
diff changeset
31
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
32 }