最近接手一个项目,通过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]本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏 举报
悬赏问题
- ¥15 file converter 转换格式失败 报错 Error marking filters as finished,如何解决?
- ¥15 ubuntu系统下挂载磁盘上执行./提示权限不够
- ¥15 Arcgis相交分析无法绘制一个或多个图形
- ¥15 关于#r语言#的问题:差异分析前数据准备,报错Error in data[, sampleName1] : subscript out of bounds请问怎么解决呀以下是全部代码:
- ¥15 seatunnel-web使用SQL组件时候后台报错,无法找到表格
- ¥15 fpga自动售货机数码管(相关搜索:数字时钟)
- ¥15 用前端向数据库插入数据,通过debug发现数据能走到后端,但是放行之后就会提示错误
- ¥30 3天&7天&&15天&销量如何统计同一行
- ¥30 帮我写一段可以读取LD2450数据并计算距离的Arduino代码
- ¥15 飞机曲面部件如机翼,壁板等具体的孔位模型