package christie.codegear;

import christie.datagear.DataGearManager;
import christie.datagear.LocalDataGearManager;
import christie.datagear.RemoteDataGearManager;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * Created by e125769 on 12/7/17.
 * CodeGearの実行
 */
public class CodeGearManager{
    private HashMap<String, DataGearManager>  dataGearManagers = new HashMap<String, DataGearManager>();
    private ThreadPoolExecutor codeGearExecutor;

    public CodeGearManager(ThreadPoolExecutor exe) {
        dataGearManagers.put("local", new LocalDataGearManager());
        codeGearExecutor = exe;
    }

    public void submit(CodeGear cg){
        codeGearExecutor.setThreadFactory(makeThreadFactory(Thread.MAX_PRIORITY));
        codeGearExecutor.execute(cg);
    }

    private ThreadFactory makeThreadFactory(final int priority) {
        return new ThreadFactory() {
            @Override
            public Thread newThread(Runnable r) {
                Thread thread = new Thread(r);
                thread.setPriority(priority);
                return thread;
            }
        };
    }

    public DataGearManager getDGM(String dest){
        return dataGearManagers.get(dest);
    }

    public void createRemoteDataGeareManager(String dist){
        dataGearManagers.put(dist, new RemoteDataGearManager());
    }
}