怎么用quartz控制任务的执行顺序

最近接手一个项目,通过web方式配置定时调度,一个调度有多个步骤,每个步骤的作用都不同,并且相互依赖。想到了用quartz+spring,做出了一个demo,可以动态的添加调度步骤,做一些到服务器上转存日志之类的工作。现在的问题是有很多个步骤都要执行,比如 job1 -->job2、job3 --> job4 --> job5、job6、job7大概就是这样一个顺序,请问如何处理呢?本人是新手,思考良久,仍未想到解决方案。。。

dream0103
dream0103 用for循环不可以吗?
大约 4 年之前 回复

4个回答

把需要并行的任务塞到一个任务队列里面,用一个线程去执行,比如下面的代码:
[code]

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;

public class OrderedJobService {
private BlockingQueue queue = new ArrayBlockingQueue(10);
private boolean running = false;

public void start() {
    running = true;
    Thread t = new Thread(new OrderedJob());
    t.start();
}

public void stop() {
    running = false;
}

public void submit(Runnable job) {
    try {
        if (queue.offer(job, 5000L, TimeUnit.MILLISECONDS) == false) {
            // 处理插入失败...
        }
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

class OrderedJob implements Runnable {

    @Override
    public void run() {
        while (running) {
            try {
                Runnable job = queue.poll(5000L, TimeUnit.MILLISECONDS);
                try {
                    if (job != null)
                        job.run();
                } catch (RuntimeException e) {
                    // TODO: handle exception
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

}
[/code]
测试代码:
[code]

public class OrderedJobs {
static int x = 0;

public static void main(String[] args) {
    OrderedJobService service = new OrderedJobService();
    service.start();
    for (int i = 0; i < 10; i++) {
        service.submit(new Runnable() {
            @Override
            public void run() {
                System.out.println(x++);
            }
        });
    }

    synchronized (service) {
        try {
            service.wait(3000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    //释放线程
    service.stop();

}

}
[/code]

当前 Quartz 并不支持任务的调度顺序,只是用来实现对某个任务的时间调度,例如每天的2点执行某个任务。你说的这个需求只能通过应用层来实现,例如当 job1 执行完毕时,自己去启动 job2 的执行,当然 job1 在什么时间启动可以通过 Quartz 来调度。总之,你需要自己写程序来配置任务的调度顺序。

把需要串行的任务塞到一个任务队列里面...不好意思,写错了

用for循环不就可以了吗?

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问