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) {