Mercurial > hg > Members > tatsuki > Alice
diff src/alice/codesegment/CodeSegmentManager.java @ 8:78b415d019de
Local DS and CS work! maybe...
author | one |
---|---|
date | Thu, 12 Jan 2012 16:02:28 +0900 |
parents | 352eb19d837d |
children | 0bb03861b5cd |
line wrap: on
line diff
--- a/src/alice/codesegment/CodeSegmentManager.java Thu Jan 12 13:48:34 2012 +0900 +++ b/src/alice/codesegment/CodeSegmentManager.java Thu Jan 12 16:02:28 2012 +0900 @@ -1,31 +1,28 @@ package alice.codesegment; -import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.LinkedBlockingQueue; -import alice.datasegment.Reply; - public class CodeSegmentManager { private static CodeSegmentManager instance = new CodeSegmentManager(); - private LinkedBlockingQueue<Reply> replyQueue = new LinkedBlockingQueue<Reply>(); - private ConcurrentHashMap<Integer, CodeSegment> seqHash = new ConcurrentHashMap<Integer, CodeSegment>(); + public LinkedBlockingQueue<CodeSegment> readyQueue = new LinkedBlockingQueue<CodeSegment>(); private CodeSegmentManager() { - Runnable replyThread = new Runnable() { + Runnable prepareThread = new Runnable() { @Override public void run() { while (true) { try { - Reply reply = replyQueue.take(); - + CodeSegment cs = readyQueue.take(); + cs.run(); } catch (InterruptedException e) { e.printStackTrace(); } } - } + }; + new Thread(prepareThread).start(); } public void create(CodeSegment cs) {