在Java中如何使用Thread.join等待线程完成_线程等待技巧分享

Thread.join()用于使当前线程等待调用线程执行完毕,支持无参阻塞等待或带超时参数的等待,适用于控制线程执行顺序,但需注意在start后调用、处理中断异常,并避免在线程池中滥用。

在Java中,Thread.join()

是一种让一个线程等待另一个线程完成的常用方法。当你希望主线程或其他线程在某个线程执行结束后再继续执行时,这个方法非常有用。下面详细介绍它的使用方式和一些实用技巧。

Thread.join() 的基本用法

调用 join() 方法的线程会暂停执行,直到被调用的线程结束。例如:

Thread thread = new Thread(() -> {
    for (int i = 0; i < 5; i++) {
        System.out.println("子线程运行: " + i);
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
});

thread.start();
try {
    thread.join(); // 主线程等待子线程完成
} catch (InterruptedException e) {
    e.printStackTrace();
}
System.out.println("子线程已完成,主线程继续执行");

在这个例子中,主线程会等待子线程打印完5次后才输出最后一句话。

带超时的线程等待

有时候你不希望无限等待,可以使用带参数的 join(long millis)join(long millis, int nanos) 方法设置最长等待时间。

try {
    thread.join(2000); // 最多等待2秒
} catch (InterruptedException e) {
    e.printStackTrace();
}

如果在指定时间内目标线程未结束,主线程将不再等待并继续执行。这有助于避免程序因某个线程卡住而一直阻塞。

多个线程的顺序等待

如果有多个线程需要按顺序完成,可以通过依次调用它们的 join() 实现:

Thread t1 = new Thread(() -> {
    System.out.println("线程1执行");
    try { Thread.sleep(1000); } catch (InterruptedException e) {}
});
Thread t2 = new Thread(() -> {
    System.out.println("线程2执行");
    try { Thread.sleep(1000); } catch (InterruptedException e) {}
});

t1.start();
t2.start();

try {
    t1.join();
    t2.join();
} catch (InterruptedException e) {
    e.printStackTrace();
}
System.out.println("所有线程已完成");

注意:这里两个 join() 是并发等待,如果你希望严格顺序执行,应在启动后立即调用第一个线程的 join()。

实际使用中的注意事项

  • 异常处理:join() 可能抛出 InterruptedException,必须捕获或声明抛出。
  • 调用时机:必须在线程 start() 之后调用 join(),否则无效。
  • 不要在已终止的线程上调用:虽然不会报错,但已经结束的线程 join() 会立即返回。
  • 慎用于线程池:线程池中的线程通常会被复用,不适合直接使用 join() 控制流程。

基本上就这些。合理使用 Thread.join() 能帮助你更好地控制多线程执行顺序,尤其是在简单的并发任务中。虽然现代开发更多使用 Future、CountDownLatch 等高级工具,但在轻量级场景下,join() 依然简洁有效。