Resultados da pesquisa a pedido "java-stream"
Maneira mais limpa de indexar uma coleção por uma propriedade dos itens que são uma coleção
eu tenho umList<Foo> e quer uma goiabaMultimap<String, Foo> onde agrupamos oFoopor cada tag de suaCollection<String> getTags() função. Eu estou usando java 8, portanto, lambdas e referências de método são boas / incentivadas. Por exemplo, se eu ...
Mesclando dois Map <String, Inteiro> com a API Java 8 Stream
Tenho dois (ou mais)Map<String, Integer> objetos. Gostaria de mesclá-los com a Java 8 Stream API de uma maneira que os valores para chaves comuns sejam o máximo dos valores. @Test public void test14() throws Exception { Map<String, Integer> m1 ...
Usando dois fluxos no Java lambda para calcular a covariância
Digamos que eu tenho duas matrizes duplas. Eu tenho experimentado o Stream a partir do Java 8. Acho que entendi as idéias principais, mas depois percebi que não tinha certeza de como manipular dois Streams ao mesmo tempo. Por exemplo, eu quero ...
Java 8: mesclar listas com API de fluxo
Eu tenho a seguinte situação Map<Key, ListContainer> map; public class ListContainer{ List<AClass> lst; }Eu tenho que mesclar todas as listaslst deListContainer objetos de umMap mapa. public static void main(String args[]){ List<AClass> ...
Como obter um fluxo de um flutuador []
Eu estava aprendendo a usar java 8 streams quando notei algo estranho. Arrays.stream() possui métodos para tudo, exceto matrizes flutuantes: Arrays.stream(int[]) : IntStreamArrays.stream(long[]) : LongStreamArrays.stream(double[]) : ...
Fluxos do Java 8: por que o fluxo paralelo é mais lento?
Estou brincando com os fluxos do Java 8 e não consigo entender os resultados de desempenho que estou obtendo. Eu tenho CPU de 2 núcleos (Intel i73520M), Windows 8 x64 e atualização de Java 8 de 64 bits 5. Estou fazendo um mapa simples por fluxo / ...
Java .parallelStream () com métodos anotados por mola
Eu tento usar oparallelStream() no DAO com Spring@Transactional anotações e fique com esse problema: @Transactional public void processCollection(Collection<Object> objects) { objects.parallelStream() .forEach(this::processOne); //throw ...
API e filas de fluxo: assine o estilo de fluxo BlockingQueue
Digamos que temos uma fila BlockingQueue<String> queue= new LinkedBlockingQueue<>();e algum outro thread coloca valores nele, então lemos como while (true) { String next = queue.take(); System.out.println("next message:" + next); }Como posso ...
O loop forEach paralelo do Java 8 aninhado apresenta desempenho ruim. Esse comportamento é esperado?
Nota: Eu já resolvi esse problema em outra postagem do SO -O uso de um semáforo dentro de uma ação de fluxo paralelo Java 8 aninhada pode DEADLOCK. Isso é ...
O uso de um semáforo dentro de uma ação de fluxo paralelo Java 8 aninhada pode DEADLOCK. Isso é um inseto?
Considere a seguinte situação: Estamos usando um fluxo paralelo do Java 8 para executar um loop forEach paralelo, por exemplo, IntStream.range(0,20).parallel().forEach(i -> { /* work done here */})O número de encadeamentos paralelos é controlado ...