package project.data.job;

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

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import kernel.util.ThreadUtils;
import project.data.DataDBService;
import project.data.model.Realtime;

public class SaveRealtimeServer implements Runnable {
	
	private Logger logger = LoggerFactory.getLogger(SaveRealtimeServer.class);
	
	private DataDBService dataDBService;
	
	public void start() {
		new Thread(this, "SaveRealtimeServer").start();
		if (logger.isInfoEnabled()) {
			logger.info("启动SaveRealtimeServer！");
		}

	}
	public void run() {
		while (true) {
			try {
				int size = RealtimeQueue.size();
				/**
				 * 现量轮询一圈
				 */
				List<Realtime> list = new ArrayList<Realtime>();
				for (int i = 0; i < size; i++) {
					Realtime item = RealtimeQueue.poll();
					list.add(item);

				}
				if (list.size() > 0) {
					dataDBService.saveBatch(list);
				}

			} catch (Throwable e) {
				logger.error(" run fail", e);
			} finally {
				ThreadUtils.sleep(60 * 1000);
			}
		}
	}

	

	public void setDataDBService(DataDBService dataDBService) {
		this.dataDBService = dataDBService;
	}

}