怎么实现MainStarter

本篇内容主要讲解“怎么实现MainStarter”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“怎么实现MainStarter”吧!

Quartz触发器配置

从触发器中配置一个通用触发MainStarter

<bean id="mainStarter" class="com.zb.timer.MainStarter" > </bean>      <bean id="mainStarterDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">	<property name="targetObject" ref="mainStarter" />	<property name="targetMethod" value="run" />	<property name="concurrent" value="false" /> </bean> <bean id="mainStarterTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">	<property name="jobDetail" ref="mainStarterDetail" />	<property name="startDelay" value="10000" />	<property name="repeatCount" value="0" />  </bean> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">	<property name="triggers">	<list>	<ref bean="mainStarterTrigger" />  	</list>	</property> </bean>

统一任务处理

MainStarter的实现

主要是任务中心来执行的

public class MainStarter{	// 任务中心	private TaskCenter taskCenter;	public void setTaskCenter(TaskCenter taskCenter) {	this.taskCenter = taskCenter;	}	public void run() {	if(taskCenter==null) {	taskCenter = new TaskCenterSupport();	}	taskCenter.run();	} }

public interface TaskCenter {	// 加载任务	public void loadTask(Task taskTracker);	public List<Task> getTasks(); 	public void run();	public void terminate(); }

任务中心存储任务，任务 Task 为代码最终执行

public abstract class Task extends Thread {	private boolean isAlive = true;	@Override	public void run() {	while (isAlive) {	try {	doRun();	} catch (Exception e) { 	logger.error("run task error.", e);	}	}	}	public void setAlive(boolean isAlive) {	this.isAlive = isAlive;	}	// 子类业务需要实现此方法，方法中为具体业务	protected abstract void doRun() throws Exception; }

具体业务实现

TaskCenter 的实现类 TaskCenterSupport

public class TaskCenterSupport implements TaskCenter {	private List<Task> tasks;	public List<Task> getTasks() {	return tasks;	}	public void loadTask(Task task) {	if (tasks == null) {	tasks = new ArrayList<>();	}	tasks.add(task);	}	public void run() {	if(CollectionUtils.isNotEmpty(tasks)){	for (Task task : tasks) {	if(task != null) {	task.setAlive(true);	task.start();	}	}	}	}	public void terminate() {	if(CollectionUtils.isNotEmpty(tasks)){	for (Task task : tasks) {	if(task != null) {	task.setAlive(false);	}	}	tasks.clear();	try {	Thread.sleep(5000);	} catch (InterruptedException e) {	logger.error(e.getMessage(),e);	Thread.currentThread().interrupt();	}	}	} }

Task 的子类 ZBTask

public class ZBTask extends Task{ 	public ZBTask () {	TaskCenter taskCenter = TaskCenterSingleton.getInstance();	taskCenter.loadTask(this);	}	public void doRun() throws Exception {	/* 具体业务实现，这里就能会定时执行，	 * 若有需要还可以在此使用休眠，	 * 这样只会把此线程挂起，不影响其他 Task 子类的执行	 */	} }

到此，相信大家对“怎么实现MainStarter”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！