GroupingByConcurrentExampleクラスのinsert code部分に入力すると、出力結果が得られるコードはどれでしょうか。
class Product {
private String name;
private double price;
public Product(String name, double price) {
this.name = name;
this.price = price;
}
public String getName() {
return name;
}
public double getPrice() {
return price;
}
@Override
public String toString() {
return "Product{name='" + name + "', price=" + price + '}';
}
}
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.ConcurrentMap;
import java.util.stream.Collectors;
public class GroupingByConcurrentExample {
public static void main(String[] args) {
List<Product> products = Arrays.asList(
new Product("AAAA", 1000.00),
new Product("BBBB", 500.00),
new Product("CCCC", 300.00),
new Product("DDDD", 900.00),
new Product("EEEE", 125.00),
new Product("FFFF", 398.00)
);
ConcurrentMap<String, List<Product>> groupedProducts =
products.parallelStream()
.collect(Collectors.groupingByConcurrent(/*insert code */));
groupedProducts.forEach((k, v) -> {
System.out.println("Price Range : " + k);
v.forEach(System.out::println);
});
}
}
出力結果
Price Range : High
Product{name='DDDD', price=900.0}
Product{name='AAAA', price=1000.0}
Price Range : Low
Product{name='CCCC', price=300.0}
Product{name='EEEE', price=125.0}
Product{name='FFFF', price=398.0}
Price Range : Medium
Product{name='BBBB', price=500.0}
A
Product::getPrice;
B
p -> {
if(p.getPrice() >= 800) return "High";
else if(p.getPrice() >= 400) return "Medium";
else return "Low";
}
C
(Product p) -> {
if(product.getPrice() >= 800) {
return "High";
} else if(product.getPrice() >= 400) {
return "Medium";
} else {
return "Low";
}
}
D
p -> {
double price = p.getPrice();
if(price >= 800) "High";
else if(price >= 400) "Medium";
else "Low";
}
E
product -> {
Predicate<Product> f = {
double price = product.getPrice();
if(price >= 800) "High";
else if(price >= 400) "Medium";
else "Low";
}
f.test(product)
}
F
if(product.getPrice() >= 800) return "High";
else if(product.getPrice() >= 400) return "Medium";
else return "Low";
↓
↓
↓
↓
↓
↓
↓
↓
↓
↓
↓
↓
↓
↓
↓
↓
B
Collectors.groupingByConcurrent()に関する問題です。
データをグループ化するためのメソッドで、大規模なデータを扱う場合や、複数のスレッドで作業を分散させたい場合に役立ちます。
並列処理の利点を活かしながら、データを分類・グループ化することができます。
本コードではグループ化された商品を、価格帯ごとに出力します。
groupingByConcurrent
public static <T,K> Collector<T,?,ConcurrentMap<K,List<T>>> groupingByConcurrent(Function<? super T,? extends K> classifier)
groupingByConcurrent(classifier, toList());
型パラメータ:
T - 入力要素の型
K - キーの型
パラメータ:
classifier - 入力要素をキーにマップする分類関数
戻り値:
グループ化操作を実装した、順序付けされていない並行なCollector
分類関数は、要素をあるキーの型Kにマップします。 コレクタによって生成されるConcurrentMap<K, List<T>>のキーは、入力要素に分類関数を適用した結果の値であり、対応する値は、分類関数の下で関連キーにマップされた入力要素を含むListになります。
ConcurrentMap<String, List<Product>> groupedProducts =
products.parallelStream()
.collect(Collectors.groupingByConcurrent(p -> {
if(p.getPrice() >= 800) return "High";
else if(p.getPrice() >= 400) return "Medium";
else return "Low";
}));