作者PTTCATKING (怀念美国猫王)
看板java
标题[问题] 请问有办法设定编号来决定排程吗
时间Wed Nov 12 14:45:46 2014
假设有二十个任务要跑
而他在DB里会有两组编号(栏位名称)
第一组是1~20的流水号
第二组是执行优先顺序(记录需等待的对象)
A 跑完 同时执行 B & CD 两条线同时跑，而B会先跑完，但要等CD都跑完後，BCD都结束
才开始跑E
A的编号就是 1 0 (无等待对象)
B的编号就是 2 1 (等待A，1是A的编号)
C的编号就是 3 1 (等待A，1是A的编号)
D的编号就是 4 3 (等待C，3是C的编号)
E的编号就是 5 2 (等待B，2是B的编号)
E的编号就是 5 4 (等待D，4是D的编号)
因为E要等两个，所以在DB里 E 会有两笔资料
请问 有没有什麽现有套件有能够执行这件事情呢
设定那两个编号，则程式执行後就按照两个编号，决定程式优先顺序，并有可能同时执行
多程序
以後维护就是设定编号就能决定跑程式的优先顺序
今天用CountDownLatch写出类似的东西，被认为是写死的东西orz
这是用排程器???或是什麽方向呢?? @O@
能否有高手指点明灯给我方向，谢谢 T_T
--
※ 发信站: 批踢踢实业坊(ptt.cc), 来自: 42.66.159.143
※ 文章网址: http://webptt.com/cn.aspx?n=bbs/java/M.1415774748.A.B71.html
1F：→ swpoker: 我想是你程式写法的问题~先把你CODE放上来吧 11/12 14:53
final CountDownLatch beginA = new CountDownLatch(1);
final CountDownLatch end = new CountDownLatch(2);
final CountDownLatch endE = new CountDownLatch(1);
final ExecutorService exec = Executors.newFixedThreadPool(3);
Runnable runA = new Runnable() {
public void run() {
try {
System.out.println("Thread A 开始..");
for(int i = 0; i < 5; i++) {
Thread.sleep(1000);
System.out.println("Thread A 执行..");
}
System.out.println("Thread A 即将结束..");
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
} finally {
beginA.countDown();
}
}
};
Runnable runB = new Runnable() {
public void run() {
try {
beginA.await();
System.out.println("Thread B 开始..");
for(int i = 0; i < 5; i++) {
Thread.sleep(1000);
System.out.println("Thread B 执行..");
}
System.out.println("Thread B 即将结束..");
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
} finally {
end.countDown();
}
}
};
Runnable runC = new Runnable() {
public void run() {
try {
beginA.await();
System.out.println("Thread C 开始..");
for(int i = 0; i < 5; i++) {
Thread.sleep(1000);
System.out.println("Thread C 执行..");
}
System.out.println("Thread C 即将结束..");
System.out.println("Thread D 开始..");
for(int i = 0; i < 5; i++) {
Thread.sleep(1000);
System.out.println("Thread D 执行..");
}
System.out.println("Thread D 即将结束..");
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
} finally {
end.countDown();
}
}
};
Runnable runE = new Runnable() {
public void run() {
try {
end.await();
System.out.println("Thread E 开始..");
for(int i = 0; i < 5; i++) {
Thread.sleep(1000);
System.out.println("Thread E 执行..");
}
System.out.println("Thread E 即将结束..");
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
} finally {
endE.countDown();
}
}
};
exec.submit(runA);
exec.submit(runB);
exec.submit(runC);
exec.submit(runE);
try {
endE.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
exec.shutdown();
※ 编辑: PTTCATKING (42.66.159.143), 11/12/2014 14:59:15
这样写大概就是 A跑完後开始跑 B跟C ，C跑完跑D ，BCD都跑完最後才跑E
只是实际上的需求是要用资料库里 两个编号来决定优先顺序
而修改第两个编号可能每只程式的执行顺序就会改变
跪求神手指点名灯 T_T
※ 编辑: PTTCATKING (42.66.159.143), 11/12/2014 17:40:05
2F：→ ssccg: 有一定要先开跑再wait再那边的理由吗? 11/12 20:12
3F：→ ssccg: 前一个跑完後select出所有该接它後面跑的来跑不行? 11/12 20:14
4F：推 yyc1217: 有点类似无限状态机(FSM)的感觉 11/12 21:06
5F：→ yyc1217: 另外用一个singleton的manager来做state之间的管理? 11/12 21:07
6F：→ luoqr: 跑完的去通知在等他的那些人开动不行吗? :S 11/12 21:24
7F：→ carylorrk: FSM(finite state mahine)不是有限状态机吗 XDD 11/13 04:06
8F：推 yyc1217: 对不起记错了..... 11/13 09:22