package alice.codesegment;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import org.apache.log4j.Logger;

public class CodeSegmentManager {

    private static CodeSegmentManager instance = new CodeSegmentManager();
    private ThreadPoolExecutor codeSegmentExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), // initial number of threads
                                                            Runtime.getRuntime().availableProcessors(),
                                                            Integer.MAX_VALUE, // keepAliveTime
                                                            TimeUnit.SECONDS,
                                                            new LinkedBlockingQueue<Runnable>());
    private Logger logger = Logger.getLogger(CodeSegmentManager.class);

    public static CodeSegmentManager get() {
        return instance;
    }

    public static void submit(CodeSegment cs) {
        CodeSegmentManager csManager = CodeSegmentManager.get();
        csManager.codeSegmentExecutor.execute(cs);
        if (csManager.logger.isDebugEnabled()) {
            csManager.logger.debug(cs.getClass().getName());
        }
    }

}