Mercurial > hg > Database > Alice

annotate src/alice/codesegment/CodeSegmentManager.java @ 282:1caa6970cf01

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Remove unused queue.
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Fri, 18 Oct 2013 02:32:40 +0900
parents 481dab56c3dc
children 2f003d5703d5
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();
70
f2d4a4686036 delete CodeSegment receive thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
12 private ThreadPoolExecutor codeSegmentExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), // initial number of threads
180
481dab56c3dc aquarium can execute on mountain lion (with java 1.6)
e095732
parents: 71
diff changeset
13 Runtime.getRuntime().availableProcessors(),
58
ebdcab7b9b04 add comment
one
parents: 57
diff changeset
14 Integer.MAX_VALUE, // keepAliveTime
21
145667a554ad run CodeSegment with ThreadPoolExecutor
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
15 TimeUnit.SECONDS,
145667a554ad run CodeSegment with ThreadPoolExecutor
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 20
diff changeset
16 new LinkedBlockingQueue<Runnable>());
71
a3a2605e16a2 change checking debug mode of logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 70
diff changeset
17 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
18
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
19 public static CodeSegmentManager get() {
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
20 return instance;
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
21 }
57
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
22
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
23 public static void submit(CodeSegment cs) {
70
f2d4a4686036 delete CodeSegment receive thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
24 CodeSegmentManager csManager = CodeSegmentManager.get();
f2d4a4686036 delete CodeSegment receive thread
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 68
diff changeset
25 csManager.codeSegmentExecutor.execute(cs);
71
a3a2605e16a2 change checking debug mode of logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 70
diff changeset
26 if (csManager.logger.isDebugEnabled()) {
a3a2605e16a2 change checking debug mode of logger
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 70
diff changeset
27 csManager.logger.debug(cs.getClass().getName());
57
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
28 }
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
29 }
44
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 39
diff changeset
30
6
c78a1cc2cd8f implements Reply
one
parents:
diff changeset
31 }