package project.redis.interal;

import java.util.Date;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;

import project.log.SysLog;
import project.log.SysLogService;

public class OffLineEventRejectExecutingHandler implements RejectedExecutionHandler {

	private SysLogService sysLogService;

	public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
		SysLog entity = new SysLog();
		entity.setLevel(SysLog.level_error);
		entity.setCreateTime(new Date());
		entity.setLog("RedisHandlerImpl处理线程池溢出，数据被丢弃，请调整线程参数。");
		sysLogService.saveAsyn(entity);
	}

	public void setSysLogService(SysLogService sysLogService) {
		this.sysLogService = sysLogService;
	}

}