如何使用Java API Streams执行此类操作？
如何使用Java API Streams执行此类操作？
提问于 2017-12-29 10:36:09
我想在一个流上连续执行以下操作。
1)。我想创建一个从2到n的数字流。
我想这可以像这样做：IntStream.range(2, n)。
2)。添加过滤器，只有当这个数字不能被已经通过这个过滤器的任何其他数字整除时，才让这个数字继续前进。
我在实现这样的过滤器时遇到了麻烦。我想我必须创建一个包含ArrayList的匿名类，我将把所有通过这个过滤器的数字存储在这个ArrayList中。这一切应该看起来像这样：
IntStream.range(2, n).filter(new IntPredicate() {
ArrayList<Integer> prev;
@Override
public boolean test(int value) {
if (prev == null) {
prev = new ArrayList();
return true;
}
for (int i = 0; i < prev.size(); i++) {
if (value % prev.get(i) == 0) {
return false;
}
}
prev.add(value);
return true;
}3)。获取Map<Integer, Integer>，其中键是数百(即100、200、300、400等)，值是每百中质数的数量。所以对于100，100，我必须找到100,199范围内的质数。
我猜很明显，在第二步之后，流中只剩下质数了。但是，我不知道如何执行第三步，也不确定第二步的实现。
你能帮我把所有的操作都做好吗？
回答 2
Stack Overflow用户
发布于 2017-12-29 10:52:10
假设您有一个方法isPrime(int) (您可以很容易地在网上找到一个实现)，下面是如何对结果进行分组：
IntStream.range(2, n)
.filter(i -> isPrime(i))
.boxed()
.collect(Collectors.groupingBy(i -> i / 100 * 100,
Collectors.summingInt(i -> 1)))Stack Overflow用户
发布于 2017-12-29 11:26:15
我稍微修改了你的代码，因为如果你在循环中检查prev null，它会得到错误的IntStream。
您可以运行代码来检查结果。
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.function.IntPredicate;
import java.util.function.Supplier;
import java.util.stream.IntStream;
public class StreamAPI {
public static void main(String[] args) {
int n = 1000;
Supplier<IntStream> intStreamSupplier = () -> IntStream.range(2, n).filter(new IntPredicate() {
ArrayList<Integer> prev = new ArrayList<>();
@Override
public boolean test(int value) {
for ( int i = 0; i < prev.size(); i++ )
{
if ( value % prev.get(i) == 0 )
{
return false;
}
}
prev.add(value);
return true;
}
});
Map<Integer, IntStream> map = new HashMap<>();
for ( int i = 0; i < n; i += 100 )
{
int j = i;
IntStream subStream = intStreamSupplier.get().filter(new IntPredicate() {
@Override public boolean test(int value) {
if ( j < value && value < ( j + 100 ) )
{
return true;
}
return false;
}
});
map.put(i, subStream);
}
for ( Map.Entry<Integer, IntStream> entry : map.entrySet() )
{
Integer key = entry.getKey();
IntStream value = entry.getValue();
System.out.println("key: " + key);
int[] arr = value.toArray();
for ( int i = 0; i < arr.length; i++ )
{
System.out.println(arr[i]);
}
}
}
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/48016725
复制相关文章
相似问题
腾讯云开发者
