Resultados da pesquisa a pedido "java-stream"
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 ...
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 ...
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 ...
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 é ...
Encontre o primeiro elemento por predicado
Acabei de começar a jogar com o Java 8 lambdas e estou tentando implementar algumas das coisas com as quais estou acostumado nas linguagens funcionais. Por exemplo, a maioria das linguagens funcionais possui algum tipo de função find que opera ...
Copie um fluxo para evitar que "o fluxo já tenha sido operado ou fechado"
Gostaria de duplicar um fluxo do Java 8 para poder lidar com ele duas vezes. eu possocollect como uma lista e obtenha novos fluxos a partir disso; // doSomething() returns a stream List<A> thing = doSomething().collect(toList()); ...
Conversão Iterable para Stream usando Java 8 JDK
Eu tenho uma interface que retornajava.lang.Iterable<T>. Gostaria de manipular esse resultado usando a API Java 8 Stream. No entanto, o Iterable não pode "transmitir". Alguma idéia de como usar o Iterable como um fluxo sem convertê-lo em lista?
encerrar ou interromper o loop de fluxo java 8 [duplicado]
Esta pergunta já tem uma resposta aqui: Limitar um fluxo por um predicado [/questions/20746429/limit-a-stream-by-a-predicate] 18 respostasEu tenho um loop de fluxo java 8 com o seguinte conteúdo: void matchSellOrder(Market market, Order ...