Spring线程池开发实战

Spring线程池结合非Spring托管Bean

Spring-Config.xml

<bean id="syncLinkingDetectTaskProcess" class="cn.vobile.trackerspt.hatask.commontask.CommonTaskProcess" parent="abstractCommonTaskProcess">
<property name="taskSize" value="100" />
<property name="taskName" value="linking_detect_taisan_add_video" />
<property name="fromTaskStatus" value="created" />
<property name="toTaskStatus" value="started" />
<property name="executor" ref="syncLinkingDetectTaskExecutor" />
<property name="commonTaskHandler" ref="syncLinkingDetectTaskHandler" />
</bean>

<bean id="syncLinkingDetectTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<property name="corePoolSize" value="3" />
<property name="maxPoolSize" value="5" />
<property name="queueCapacity" value="200" />
</bean>

private Executor            executor;

public void setExecutor(Executor executor) {
this.executor = executor;
}

public void dealProcessDetail(ProcessControl pc) {
Assert.notNull(taskName, "taskName must not be null");
Assert.notNull(fromTaskStatus, "fromTaskStatus must not be null");
Assert.notNull(toTaskStatus, "toTaskStatus must not be null");

List<WorkingCommonTask> workingTasks = commonTaskService.getWorkingTasks(taskName, fromTaskStatus, taskSize);
if (CollectionUtils.isEmpty(workingTasks)) {
logger.info("No " + taskName + " task need to process: taskStatus=" + fromTaskStatus.getCode());
return;
}

for (final WorkingCommonTask workingTask : workingTasks) {
if (null == workingTask) {
continue;
}

boolean isUpdateSuccess = commonTaskService.updateWorkingTaskStatus(workingTask.getId(), fromTaskStatus, toTaskStatus);
if (!isUpdateSuccess) {
logger.info("The " + taskName + " task has been processed: id=" + workingTask.getId() + ", fromTaskStatus=" + fromTaskStatus + ", toTaskStatus=" + toTaskStatus);
continue;
}

try {
executor.execute(new Runnable() {
@Override
public void run() {
try {
commonTaskHandler.handle(workingTask.getId());
} catch (Exception e) {
logger.error(taskName + " task handle failed: " + workingTask, e);
}
};
});
} catch (Exception e) {
logger.error("Execute " + taskName + "  failed: " + workingTask, e);
if (e instanceof TaskRejectedException) {
break;
}
}
}
}