Sync Scheduled方法运行异步方法-Spring@Scheduled，@Async

Question

我使用的是Spring的@计划和@异步注释。

我的目的

计划一个同步方法——它运行一个for循环，而这个循环将运行一个异步方法，因此循环中的下一个值不需要等到方法完成。

见下面我的代码：

/**
 *  Explanation: Scheduling async task for getting new hired candidates from the Lumesse Queue and saving the received data.
 */
@LoggableDebug
@Scheduled(fixedRateString = "${scheduler.insertCandidateFromQueueInDB.fixedRate}")
public void insertNewHiredCandidateFromQueueInDbScheduler() {
    for(EnvironmentContext environmentContext: context) {
        if(environmentContext.isActive()) {
            environmentAsyncHandlerInsertNewHiredCandidateFromQueueInDb(environmentContext);
        }
    }
}

/**
 * @param environmentContext
 * Explanation: Async task for getting new hired candidates from the Lumesse Queue and saving the received data.
 */
@LoggableDebug
@Async
public void environmentAsyncHandlerInsertNewHiredCandidateFromQueueInDb(EnvironmentContext environmentContext) {
    CandidateLumesse candidateLumesse;
    candidateLumesse = lumesseConnectorService.getNewHiredCandidateDataFromQueue(environmentContext);   
}

问题：

我的异步方法不会在不同的任务上运行。只有在我将@Async注释也放在我的计划方法上时，它才起作用。但我的计划方法将异步运行到，这不是我想要的。计划的方法需要同步运行，但for循环中被调用的方法需要异步运行。

尝试

我试过这样的解决方法：

Spring@Async方法调用@Scheduled方法内部

-

@LoggableDebug
@Scheduled(fixedRateString = "${scheduler.insertCandidateFromQueueInDB.fixedRate}")
public void insertNewHiredCandidateFromQueueInDbScheduler() {
    for(EnvironmentContext environmentContext: context) {
        if(environmentContext.isActive()) {
            asyncServiceExecutor.environmentAsyncHandlerInsertNewHiredCandidateFromQueueInDb(environmentContext);
        }
    }
}

现在的问题是我的计划任务被执行了两次...

最新消息

我做了一些更多的日志记录和我的对象只被创建一次：

2018-02-06 13:17:19.053  WARN 13144 --- [           main] 
c.d.l.c.s.LumesseConnectorScheduler      : #### SCHEDULER CLASS CONSTRUCTOR

我的固定利率是3000-

2018-02-06 13:17:26.388  WARN 13144 --- [pool-7-thread-1] 
c.d.l.c.s.LumesseConnectorScheduler      : #### START SCHEDULING
2018-02-06 13:17:26.397  WARN 13144 --- [pool-7-thread-1] 
c.d.l.c.s.LumesseConnectorScheduler      : #### START SCHEDULING

-

有什么想法吗？

Answer 1

-

尝试

我试过这样的解决方法：

Spring@Async方法调用@Scheduled方法内部

，但我遇到了一个新问题，调度器执行了两次：

解决方案

@user27149尝试删除@ConfigurationProperties（prefix=“environment”）或@Component

所以我改变了

@Component
@ConfigurationProperties(prefix="environment")
public class LumesseConnectorScheduler {

    private List<EnvironmentContextImpl> context;

致：

@Component
public class LumesseConnectorScheduler {

    @Autowired
    EnvironmentContextList environmentContextList;

谢谢你的回答！