package com.product.org.admin.util;
import java.util.LinkedList;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.product.core.entity.FieldSetEntity;
import com.product.core.spring.context.SpringBeanUtil;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.org.admin.service.TimeTaskChangeService;


/**
 * 消息服务，添加消息，读取消息
 * @author shicf
 *
 */
@Component
public class ExecuteOtherProcessThread   {
	/**自已实例**/
	private static ExecuteOtherProcessThread executeOtherProcessThread;
	/**内部线程**/
	private ProcessThread processThread=null;
	@Autowired
	TimeTaskChangeService timeTaskChangeServices;
	/** 生成的新消息队列**/
	private static LinkedList <FieldSetEntity> datas=new LinkedList<>();
	
	/**
	 * 静态工厂方法 获取当前对象实例 多线程安全单例模式(使用双重同步锁)
	 */
	public static synchronized ExecuteOtherProcessThread getInstance() {

		if (executeOtherProcessThread == null) {
			synchronized (ExecuteOtherProcessThread.class) {
				if (executeOtherProcessThread == null) {
					executeOtherProcessThread=(ExecuteOtherProcessThread) SpringBeanUtil.getBean("executeOtherProcessThread");
				}
			}
		}
		executeOtherProcessThread.start();
		return executeOtherProcessThread;
	}
	/**
	 * 启动缓存的刷新线程
	 */
	public  void start() {
		if(processThread ==null || processThread.getState()== Thread.State.TERMINATED ) {
			processThread=new ProcessThread();
			processThread.start();
			SpringMVCContextHolder.getSystemLogger().info("Thread Of Refresh Cache Is Starting.............");
		}
	}
	/**
	 * 把用户信息添加对列中
	 * @param user
	 */

	public synchronized void appendFieldSetEntity(FieldSetEntity data) {
		if(data!=null) {
			datas.add(data);
		}
	}
	/**
	 * 取刷新表队表的第一个
	 * @return
	 */
	public synchronized void pop() {
		while(!datas.isEmpty()) {
			FieldSetEntity ff=datas.pop();
			if(timeTaskChangeServices ==null ) {
				timeTaskChangeServices=(TimeTaskChangeService) SpringBeanUtil.getBean("timeTaskChangeServices");
			}
			timeTaskChangeServices.executeServiceChange(ff,ff.getTableName());
		}
	}
	/**
	 * 内部线程，定时刷新缓存
	 * @author shicf
	 *
	 */
	class ProcessThread extends Thread {	
		@Override
		public void run() {
			try {
				while(true) {
					sleep(2000);// 执行间隔2s
					pop();
				}
			} catch (InterruptedException e) {
				e.getStackTrace();
			}
		}
	}

}