iteye_11152 2011-11-10 16:49
浏览 1124
已采纳

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

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

  • 写回答

4条回答 默认 最新

  • qiemengdao 2011-11-13 15:42
    关注

    把需要并行的任务塞到一个任务队列里面,用一个线程去执行,比如下面的代码:
    [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]

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

悬赏问题

  • ¥15 使用C#,asp.net读取Excel文件并保存到Oracle数据库
  • ¥15 C# datagridview 单元格显示进度及值
  • ¥15 thinkphp6配合social login单点登录问题
  • ¥15 HFSS 中的 H 场图与 MATLAB 中绘制的 B1 场 部分对应不上
  • ¥15 如何在scanpy上做差异基因和通路富集?
  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 虚心请教几个问题,小生先有礼了
  • ¥30 截图中的mathematics程序转换成matlab