我不确定自己的前进方向是否正确，但目前仍无法解决。
我想要实现的是，我想根据其父类别获取项目列表。ParentCategory --< Category --< Item
而且对CompletionStage还不熟悉。
因此，这里有2个查询。第一个查询是获取ParentCategory的列表。然后，我将遍历该列表以获取每个ParentCategory的项目列表
ParentCategoryDao {
findParentCategoriesByShop(int shopId);
}
ItemDao {
//joined query of item and child category
findItemByChildCategory(final int parentCategoryId)
}
在控制器中:
public CompletionStage<List<ProcessClass>> retrieveItems(final int shopId) {
parentCategoryDao.findParentCategoriesByShop(shopId).thenApplyAsync(parentCategoryStream ->{
ParentCategoryJson parentCategoryJson = new ParentCategoryJson();
for(ParentCategory parentCategory : parentCategoryStream.collect(Collectors.toList())) {
processClassJson.setProcessClassId(parentCategory.getId());
processClassJson.setProcessClassName(processClass.getProcessClass());
itemDao.findItemByChildCategory(parentCategory.getId()).thenApplyAsync(itemStream ->{
// Do operations on forming a list of items
}, ec.current());
//then maybe after is something like
processClassJson.setItemList(itemList);
}
},ec.current())
}
顺便说一句，我正在使用Play Framework。
任何帮助是极大的赞赏。
最佳答案
令人惊讶的是，您没有在thenApplyAsync块中返回任何内容。另外，应仅从thenCompose调用非阻塞函数，以避免嵌套的CompletionStage。无论如何，下面是应该解决您的问题的代码。
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
import java.util.stream.Collectors;
....
public static CompletionStage<List<Object>> retrieveItems(final int shopId) {
return parentCategoryDao
.findParentCategoriesByShop(shopId)
.thenComposeAsync(
stream ->
resultsOfAllFutures(
stream
.map(
parentCategory ->
itemDao
.findItemByChildCategory(parentCategory.getId())
.thenApplyAsync(
itemStream -> {
// Do operations on forming a list of items
return null;
}))
.collect(Collectors.toList())));
}
public static <T> CompletableFuture<List<T>> resultsOfAllFutures(
List<CompletionStage<T>> completionStages) {
return CompletableFuture.completedFuture(null)
.thenApply(
__ ->
completionStages
.stream()
.map(future -> future.toCompletableFuture().join())
.collect(Collectors.toList()));
}