※ 引述《PTTCATKING (怀念美国猫王)》之铭言：
: 假设有二十个任务要跑
: 而他在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
可以用java8的CompletableFuture啊
class MyTask implements Runnable {
private String name;
public MyTask(String name) {
this.name = name;
}
public void run() {
try {
System.out.printf("Task %s\n", name);
Thread.sleep((long) (new Random().nextDouble() * 1000));
System.out.printf("Task %s complete\n", name);
} catch (Exception e){}
}
}
public class Scheduler {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(3);
CompletableFuture<Void> a = CompletableFuture
.allOf()
.thenRunAsync(new MyTask("a"), executor);
CompletableFuture<Void> b = CompletableFuture
.allOf(a)
.thenRunAsync(new MyTask("b"), executor);
CompletableFuture<Void> c = CompletableFuture
.allOf(a)
.thenRunAsync(new MyTask("c"), executor);
CompletableFuture<Void> d = CompletableFuture
.allOf(c)
.thenRunAsync(new MyTask("d"), executor);
CompletableFuture<Void> e = CompletableFuture
.allOf(b, d)
.thenRunAsync(new MyTask("e"), executor);
CompletableFuture<Void> all = CompletableFuture
.allOf(a,b,c,d,e);
all.get();
System.out.print("Complete");
executor.shutdown();
}
}
出来结果
Task a
Task a complete
Task c
Task b
Task b complete
Task c complete
Task d
Task d complete
Task e
Task e complete
Complete
因为用random sleep，所以每次结果会稍微不同哟!!