并行执行相同的@Sceduled方法

Question

我有一个用@scheduled注解的方法。这是一个运行时间相当长的方法。我需要使用线程池并行运行相同的方法。有可能吗？代码是：

@Scheduled(fixedRate=100)
public void run() {
    Job job = QUEUE.take();
    job.run(); //Takes a long time
}

该队列有许多作业，我希望使用Spring的Scheduled注解并行运行它们。

Answer 1

我认为你可以通过使用spring的"@Async“将Job.run方法更改为异步方法，或者通过另一种方式创建自己的线程池来完成这项工作。

/**
 * Created by roman.luo on 2016/9/14.
 */
@Component
@Scope("prototype")
public class JobDelegate implements Job {

    private Job job;

    public JobDelegate(Job job) {
        this.job = job;
    }

    @Async
    public void run(){
        job.run();
    }
}

/**
 * Created by roman.luo on 2016/9/14.
 */
@Component
public class Sceduled extends ApplicationObjectSupport{

    @Scheduled(fixedRate = 100)
    public void run(){
        Job job = QUEUE.take();
        Job jobDelegate = getApplicationContext().getBean(JobDelegate.class,job);
        jobDelegate.run();
    }

}

记住配置spring xml文件：

<task:executor id="myexecutor" pool-size="5"  />  
<task:annotation-driven executor="myexecutor"/>