Thread.join()
方法用于等待线程执行完毕。在 Java 中,可以在需要等待某个线程执行完毕后再执行后续代码的场景中使用 Thread.join()
。而并发集合类(如 ConcurrentHashMap
、CopyOnWriteArrayList
等)是 Java 提供的一组线程安全的集合类,它们可以在多线程环境下安全地使用。
Thread.join()
方法的使用场景通常与线程同步和协作有关。如果你需要在某个线程执行完毕后再执行后续代码,并且这个后续代码需要访问并发集合类,那么可以在访问并发集合类之前调用 Thread.join()
方法。
以下是一个简单的示例,展示了如何在多线程环境下使用 Thread.join()
和并发集合类:
import java.util.concurrent.ConcurrentHashMap;
public class JoinExample {
public static void main(String[] args) {
ConcurrentHashMap<String, String> concurrentMap = new ConcurrentHashMap<>();
Thread thread1 = new Thread(() -> {
System.out.println("Thread 1 started");
try {
// 模拟耗时操作
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Thread 1 finished");
// 在 Thread 1 执行完毕后,向并发集合类中添加元素
concurrentMap.put("key1", "value1");
});
Thread thread2 = new Thread(() -> {
System.out.println("Thread 2 started");
try {
// 模拟耗时操作
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Thread 2 finished");
});
thread2.start();
try {
// 等待 Thread 2 执行完毕
thread2.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
thread1.start();
try {
// 等待 Thread 1 执行完毕
thread1.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 输出并发集合类的元素
concurrentMap.forEach((key, value) -> System.out.println("Key: " + key + ", Value: " + value));
}
}
在这个示例中,我们创建了两个线程 thread1
和 thread2
。thread2
首先启动并执行完毕,然后 thread1
启动。在 thread2
执行完毕后,我们向 concurrentMap
中添加了一个元素。接着,在 thread1
执行完毕后,我们输出了 concurrentMap
中的所有元素。通过使用 Thread.join()
方法,我们确保了在访问并发集合类之前,线程已经执行完毕。