java - 如何从另一个线程启动一个线程并在执行后重新启动一个线程？

Question

我有 2 个线程，“主”线程启动辅助线程来运行一个小进程。

“主”线程必须等待辅助线程几秒钟才能完成该过程，在此之后，“主”线程必须再次启动，无论辅助线程的过程发生了什么。

如果辅助进程提前结束，“主”线程必须再次开始工作。

如何从另一个线程启动一个线程，等待执行结束，然后重新启动该线程？

我这里有一个代码，但是ExampleRun类必须等待，例如10秒然后重新开始，无论MyProcess发生了什么

public class ExampleRun {
public static void main(String[] args) {

    MyProcess t = new MyProcess();
    t.start();

    synchronized (t) {
        try {
            t.wait();
        } catch (InterruptedException e) {
            System.out.println("Error");
        }
    }
}

}

public class MyProcess extends Thread {

public void run() {
    System.out.println("start");

    synchronized (this) {
        for (int i = 0; i < 5; i++) {

            try {
                System.out.println("I sleep");
                sleep(1000);

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        flag = true;
        System.out.println("Wake up");
        notify();
    }

}
}

Answer 1

实现您想要的效果的最简单方法是使用Thread.join(timeout)。

此外，不要在Thread上使用synchronized、wait或notify > 对象。这会干扰 Thread.join 的实现。请参阅documentation了解详情。

您的主程序如下所示:

public static void main(String[] args) {
    MyProcess t = new MyProcess();
    t.start();

    try {
        t.join(10000L);
    } catch (InterruptedException ie) {
        System.out.println("interrupted");
    }

    System.out.println("Main thread resumes");
}

请注意，当主线程在 join() 调用后恢复时，它无法判断子线程是否已完成或调用是否超时。要对此进行测试，请调用 t.isAlive()。

您的子线程当然可以执行任何操作，但重要的是不要对其自身使用 synchronized、wait 或 notify。例如，下面是避免使用这些调用的重写:

class MyProcess extends Thread {
    public void run() {
        System.out.println("MyProcess starts");
        for (int i = 0; i < 5; i++) {
            try {
                System.out.println("MyProcess sleeps");
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("MyProcess finishes");
    }
}