Потоки могут помочь нам выполнить большую обработку, которую мы традиционно выполняли бы с помощью коллекций. Однако между ними есть некоторые существенные различия.
Коллекции работают с памятью. К тому времени, когда мы используем коллекции, все элементы коллекции уже находятся в памяти и доступны. Потоки работают с набором элементов, все из которых еще не находятся в памяти. Потоки также могут быть бесконечными.
Операции по сбору средств являются обязательными. Они работают над одним предметом за раз. Потоковые операции работают со всем набором. Немного забавно, что, хотя вся коллекция находится в памяти, операции сбора работают с одним элементом за раз, в то время как потоковые операции работают со всем набором, хотя не все элементы находятся в памяти.
Рассмотрим приведенный ниже java-код. Он производит пифагорейские тройки в заданном диапазоне целых чисел. Это числа, которые удовлетворяют уравнению a*a +*c .
IntStream.rangeClosed(1, 10)
.boxed()
.flatMap(a -> IntStream.rangeClosed(a, 15)
.mapToObj( b -> new double[]{a, b, Math.sqrt(a*a + b*b)}))
.filter(t -> t[2] % 1 == 0)
.forEach(t -> System.out.println(t[0] + ", " + t[1] + ", " + t[2]));
Сначала получите поток диапазона целых чисел, используя IntStream.rangeClosed(1, 10) .
Исходя из этого, получите поток целых чисел, используя boxed() .
Исходя из этого, получите все возможные триплеты, используя flatMap() . (См. Демонстрацию Плоской карты
Затем отфильтруйте только те, которые удовлетворяют уравнению.
Обратите внимание, что после каждой операции мы получаем поток. Мы работаем не с отдельными элементами, а со всем набором. Приведенная ниже программа показывает результат после каждого шага.
Кроме того, в приведенной ниже полной программе обратите внимание на тонкую разницу в двух способах применения окончательного фильтра. В первой версии фильтр применяется после операции Плоская карта , а во второй версии фильтр применяется в рамках операции Плоская карта . Конечный результат в обоих случаях одинаков.
Полная программа.
import java.util.stream.IntStream;
public class PythogoreanTriplets {
public static void main(String[] args) {
System.out.println("\n\nStep 1 - Get stream of Integers 1 to 10 \n------");
IntStream.rangeClosed(1, 10)
.boxed()
.forEach(e -> System.out.print(e + " "));
System.out.println("\n\nStep 2 - Get possible triplets \n------");
IntStream.rangeClosed(1, 10)
.boxed()
.flatMap(a -> IntStream.rangeClosed(a, 10)
.mapToObj( b -> new double[]{a, b, Math.sqrt(a*a + b*b)}))
.forEach(t -> System.out.println(t[0] + ", " + t[1] + ", " + t[2]))
;
System.out.println("\n\nStep 3a - Filter the right ones, one way \n------");
IntStream.rangeClosed(1, 10)
.boxed()
.flatMap(a -> IntStream.rangeClosed(a, 15)
.mapToObj( b -> new double[]{a, b, Math.sqrt(a*a + b*b)}))
.filter(t -> t[2] % 1 == 0)
.forEach(t -> System.out.println(t[0] + ", " + t[1] + ", " + t[2]));
System.out.println("\n\nStep 3b - Filter the right ones, another way \n------");
IntStream.rangeClosed(1, 10)
.boxed()
.flatMap(a -> IntStream.rangeClosed(a, 15)
.mapToObj( b -> new double[]{a, b, Math.sqrt(a*a + b*b)})
.filter(t -> t[2] % 1 == 0))
.forEach(t -> System.out.println(t[0] + ", " + t[1] + ", " + t[2]));
}
}
Пример основан на примере из книги Современная разработка Java
Результатом будет
Step 1 - Get stream of Integers 1 to 10 ------ 1 2 3 4 5 6 7 8 9 10 Step 2 - Get possible triplets ------ 1.0, 1.0, 1.4142135623730951 1.0, 2.0, 2.23606797749979 1.0, 3.0, 3.1622776601683795 1.0, 4.0, 4.123105625617661 1.0, 5.0, 5.0990195135927845 1.0, 6.0, 6.082762530298219 1.0, 7.0, 7.0710678118654755 1.0, 8.0, 8.06225774829855 1.0, 9.0, 9.055385138137417 1.0, 10.0, 10.04987562112089 2.0, 2.0, 2.8284271247461903 2.0, 3.0, 3.605551275463989 2.0, 4.0, 4.47213595499958 2.0, 5.0, 5.385164807134504 2.0, 6.0, 6.324555320336759 2.0, 7.0, 7.280109889280518 2.0, 8.0, 8.246211251235321 2.0, 9.0, 9.219544457292887 2.0, 10.0, 10.198039027185569 3.0, 3.0, 4.242640687119285 3.0, 4.0, 5.0 3.0, 5.0, 5.830951894845301 3.0, 6.0, 6.708203932499369 3.0, 7.0, 7.615773105863909 3.0, 8.0, 8.54400374531753 3.0, 9.0, 9.486832980505138 3.0, 10.0, 10.44030650891055 4.0, 4.0, 5.656854249492381 4.0, 5.0, 6.4031242374328485 4.0, 6.0, 7.211102550927978 4.0, 7.0, 8.06225774829855 4.0, 8.0, 8.94427190999916 4.0, 9.0, 9.848857801796104 4.0, 10.0, 10.770329614269007 5.0, 5.0, 7.0710678118654755 5.0, 6.0, 7.810249675906654 5.0, 7.0, 8.602325267042627 5.0, 8.0, 9.433981132056603 5.0, 9.0, 10.295630140987 5.0, 10.0, 11.180339887498949 6.0, 6.0, 8.48528137423857 6.0, 7.0, 9.219544457292887 6.0, 8.0, 10.0 6.0, 9.0, 10.816653826391969 6.0, 10.0, 11.661903789690601 7.0, 7.0, 9.899494936611665 7.0, 8.0, 10.63014581273465 7.0, 9.0, 11.40175425099138 7.0, 10.0, 12.206555615733702 8.0, 8.0, 11.313708498984761 8.0, 9.0, 12.041594578792296 8.0, 10.0, 12.806248474865697 9.0, 9.0, 12.727922061357855 9.0, 10.0, 13.45362404707371 10.0, 10.0, 14.142135623730951 Step 3a - Filter the right ones, one way ------ 3.0, 4.0, 5.0 5.0, 12.0, 13.0 6.0, 8.0, 10.0 8.0, 15.0, 17.0 9.0, 12.0, 15.0 Step 3b - Filter the right ones, another way ------ 3.0, 4.0, 5.0 5.0, 12.0, 13.0 6.0, 8.0, 10.0 8.0, 15.0, 17.0 9.0, 12.0, 15.0
Оригинал: “https://dev.to/vikrampawar/java-streams-operate-on-the-whole-set-4fac”