gpt4 book ai didi

java - 我可以使用 CountDownLatch 控制线程执行顺序吗?

转载 作者:行者123 更新时间:2023-11-30 04:20:53 25 4
gpt4 key购买 nike

我有任务要做。我必须创建 4 个服务 A、B、C 和 D。每个服务应该有自己的线程。一个服务只能在它所依赖的所有服务都启动后才启动,并且仅当依赖于某个服务的所有服务都停止后,该服务才应停止。应尽可能并行启动和停止服务。服务 B 和 C 依赖于服务 A服务 D 依赖于服务 B要启动服务D,需要启动服务A和B要停止服务A,必须先停止服务B、D和C服务 B 和 C 可以在 A 启动后立即并行启动。相反,它们可以并行停止。

您对如何解决这个问题有什么建议吗?我最近 10 天一直在尝试这样做...我可以使用 CountDownLatch 或其他东西来完成吗?任何建议都是值得赞赏的。

最佳答案

您可以使用阻塞队列在工作线程和主线程之间进行通信,例如

public static void main(String[] args) {
BlockingQueue<String> queue = new LinkedBlockingQueue<>();
Thread t1 = new Thread(new A(queue));
t1.start();
if(queue.take().equals("Started A")) {
Thread t2 = new Thread(new B(queue));
t2.start();
Thread t3 = new Thread(new C());
t3.start();
}
if(queue.take().equals("Started B")) {
Thread t4 = new Thread(new D());
t4.start();
}
}

public class A implements Runnable {
private BlockingQueue queue;
private volatile boolean isCancelled = false;

public A(BlockingQueue queue) {
this.queue = queue;
}

public void cancel() {
isCancelled = true;
}

public void run() {
// initialization code
queue.offer("Started A");
while(!isCancelled) {
...
}
queue.offer("Stopped A");
}
}

使用类似的逻辑来停止线程(在服务中使用 while(!isCancelled) 循环,并让主线程在以下情况下调用服务上的 cancel()是时候阻止他们了)。

关于java - 我可以使用 CountDownLatch 控制线程执行顺序吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17093432/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com