Resultados de la búsqueda a petición "java-stream"
Flujos de Java 8: ¿por qué el flujo paralelo es más lento?
Estoy jugando con las transmisiones de Java 8 y no puedo entender los resultados de rendimiento que obtengo. Tengo una CPU de 2 núcleos (Intel i73520M), Windows 8 x64 y actualización Java 8 de 64 bits 5. Estoy haciendo un mapa simple sobre la ...
Referencia de Java 8 a un método estático versus método de instancia
digo que tengo el siguiente código public class A { int x; public boolean is() {return x%2==0;} public static boolean is (A a) {return !a.is();} }y en otra clase ... List<A> a = ... a.stream().filter(b->b.isCool()); ...
Fusionar dos Map <String, Integer> con Java 8 Stream API
Tengo dos (o más)Map<String, Integer> objetos. Me gustaría fusionarlos con Java 8 Stream API de manera que los valores para las claves comunes deberían ser el máximo de los valores. @Test public void test14() throws Exception { Map<String, ...
Java 8 anidado paralelo para cada bucle de rendimiento pobre. ¿Se espera este comportamiento?
Nota: ya abordé este problema en otra publicación SO:El uso de un semáforo dentro de una acción de flujo paralelo anidado de Java 8 puede DEADLOCK. ¿Es esto un ...
Stream API y colas: suscríbete a BlockingQueue stream-style
Digamos que tenemos una cola BlockingQueue<String> queue= new LinkedBlockingQueue<>();y algún otro hilo pone valores en él, luego lo leemos como while (true) { String next = queue.take(); System.out.println("next message:" + next); }¿Cómo puedo ...
El uso de un semáforo dentro de una acción de flujo paralelo anidado de Java 8 puede DEADLOCK. ¿Es esto un error?
Considere la siguiente situación: estamos utilizando una secuencia paralela Java 8 para realizar un ciclo paralelo para cada ciclo, por ejemplo, IntStream.range(0,20).parallel().forEach(i -> { /* work done here */})El número de subprocesos ...
¿Cómo mapear a múltiples elementos con flujos Java 8?
Tengo una clase como esta: class MultiDataPoint { private DateTime timestamp; private Map<String, Number> keyToData; }y quiero producir, para cada MultiDataPoint class DataSet { public String key; List<DataPoint> dataPoints; } class DataPoint{ ...
Encuentra el primer elemento por predicado
Acabo de comenzar a jugar con Java 8 lambdas y estoy tratando de implementar algunas de las cosas a las que estoy acostumbrado en lenguajes funcionales. Por ejemplo, la mayoría de los lenguajes funcionales tienen algún tipo de función de ...
terminar o romper el bucle de flujo de Java 8 [duplicar]
Esta pregunta ya tiene una respuesta aquí: Limitar una secuencia por un predicado [/questions/20746429/limit-a-stream-by-a-predicate] 18 respuestasTengo un bucle de flujo de Java 8 con el siguiente contenido: void matchSellOrder(Market market, ...
Java 8 Stream - Cómo volver a reemplazar el contenido de una cadena con una lista de elementos para encontrar
Deseo reemplazar el siguiente código usando java8 .stream () o .foreach (). Sin embargo, estoy teniendo problemas para hacer esto. Probablemente sea muy fácil, pero estoy encontrando la forma funcional de pensar una lucha :) Puedo iterar, no ...