1

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

你对如何解决这个问题有什么建议吗？我试图在过去 10 天里这样做......我可以用 CountDownLatch 还是用其他东西来做？任何建议都是可观的。

4

1 回答 1

2

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

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()需要停止服务时让主线程调用服务）。

于 2013-06-13T17:48:09.533 回答