package com.dy.rtuMw.server.rtuData;

import java.util.ArrayList;
import java.util.List;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;


public class TaskPool {

	private static Logger log = LogManager.getLogger(TaskPool.class.getName()) ;
	
	private static List<TaskSurpport> tasks = new ArrayList<TaskSurpport>() ;

	private static Integer taskTotal = 0 ;
	
	private static TreeConfig taskTreeConf ;
	
	
	public static void setTaskTreeCofig(TreeConfig conf){
		taskTreeConf = conf ;
	}

	/**
	 * 得到任务树实例总数
	 * @return
	 */
	public static Integer totalTasks() {
		return taskTotal ;
	}
	
	
	/**
	 * 得到任务
	 * 多线程环境下运行
	 * @return
	 */
	public static TaskSurpport popTask(){
		synchronized(tasks){
			TaskSurpport t = (tasks.size() > 0)?tasks.get(0):null ;
			if(t != null){
				tasks.remove(0) ;
			}else{
				try {
					t = newTaskTree() ;
				} catch (Exception e) {
					log.error(e.getMessage() == null?"实例化上行数据处理任务对象树失败！" : e.getMessage(), e);
				} finally {
					if(t == null){
						log.error("实例化上行数据处理任务对象失败！" );
					}else{
						taskTotal++ ;
					}
				}
			}

			return t ;
		}
	}
	
	/**
	 * 放回任务
	 * 多线程环境下运行
	 * 这里需要同步锁，因为上面方法中执行完tasks.get(0)且未执行tasks.remove(0)期间，本方法执行并且执行完，那么后期就会出乱子
	 * @param t
	 */
	public static void freeAndCleanTask(TaskSurpport t){
		synchronized(tasks) {
			if (t != null) {
				boolean find = false;
				for (TaskSurpport tin : tasks) {
					if (tin == t) {
						find = true;
						break;
					}
				}
				if (!find) {
					t.cleanMeAndSubs();
					tasks.add(0, t);
				}
			}
		}
	}
	
	/**
	 * 实例化任务对象树
	 * @return
	 * @throws Exception
	 */
	private static TaskSurpport newTaskTree() throws Exception{
		TaskSurpport t = null ;
		if(taskTreeConf != null){
			t = newTask(null, taskTreeConf.taskConf, taskTreeConf.subTreeConfs) ;
		}
		return t ;
	}
	
	private static TaskSurpport newTask(TaskSurpport root, TaskConfig taskConf, TreeConfig[] subTreeConfs) throws Exception{
		TaskSurpport t = null ;
		if(taskConf != null){
			t = instanceTask(taskConf.clazz) ;
			if(t != null){
				t.conf = taskConf ;
				t.root = root ;
				if(root == null){
					root = t ;
				}
				newSubTask(root, t, subTreeConfs);
			}
		}
		return t ;
	}
	private static void newSubTask(TaskSurpport root, TaskSurpport parent, TreeConfig[] treeConfs)throws Exception{
		if(parent != null && treeConfs != null && treeConfs.length > 0){
			parent.subTasks = new TaskSurpport[treeConfs.length] ;
			for(int i = 0 ; i < treeConfs.length; i++){
				parent.subTasks[i] = newTask(root, treeConfs[i].taskConf, treeConfs[i].subTreeConfs) ;
			}
		}
	}
	private static TaskSurpport instanceTask(String clazz)throws Exception{
		Class<?> c = Class.forName(clazz);
		if (c == null) {
			throw new Exception("实例化上行数据处理任务对象树失败！任务类为" + clazz + "！");
		}else{
			return (TaskSurpport)c.getDeclaredConstructor().newInstance();
			//return (TaskSurpport)c.newInstance();
		}
	}

}