Resultados da pesquisa a pedido "concurrency"
Como implementar o Futuro como Aplicável no Scala?
Suponha que eu precise executar dois cálculos simultâneos, esperar pelos dois e depois combinar seus resultados. Mais especificamente, preciso executarf1: X1 => Y1 ef2: X2 => Y2 simultaneamente e depois chamef: (Y1, Y2) => Y para finalmente obter ...
Modelos de simultaneidade em nodejs
Alguém sabe quais são os modelos de memória e de encadeamento no nodejs? Em particular, éii++ atômico? Comporta-se como seii estavamvolatile em Java 1.5, em Java 1.4, em C, ou não?
Listar a sequência <Future> to Future <List>
Estou tentando converterList<CompletableFuture<X>> paraCompletableFuture<List<T>>. Isso é bastante útil, pois quando você tem muitas tarefas assíncronas e precisa obter resultados de todas elas. Se algum deles falhar, o futuro final falhará. É ...
ReentrantLock não fornece o resultado esperado
Eu criei um programa de consumidor produtor usando o recurso de threads (aguarde e notifique). O código é - /** * Message.java ( Common object ) */ package threads; import java.util.concurrent.locks.ReentrantLock; /** * @author chouhan_r * */ ...
Problema de mônada STM
Este é apenas um cenário hipotético para ilustrar minha pergunta. Suponha que haja dois threads e um TVar compartilhados entre eles. Em um segmento, há um bloco atômico que lê o TVar e leva 10s para ser concluído. Em outro segmento, há um bloco ...
Lista de processos de itens 'N' com vários encadeamentos
eu tenhoList doN itens e eu quero dividir issoList de maneira seqüencial entre um número fixo dethreads. Por sequencial, quero dizer, quero passar1 to N/4primeirothread , N/4 + 1 to N/2para o segundo segmento eN/2+1 to N para terceirothreadAgora ...
Processamento simultâneo usando Stanford CoreNLP (3.5.2)
Estou enfrentando um problema de simultaneidade ao anotar várias frases simultaneamente. Não está claro para mim se estou fazendo algo errado ou se há algum erro no CoreNLP. Meu objetivo é anotar frases com o pipeline "tokenize, ssplit, pos, ...
Como o LongAdder tem um desempenho melhor que o AtomicLong
Vejo como o AtomicInteger do Java funciona internamente com a operação CAS (Compare And Swap). Basicamente, quando vários encadeamentos tentam atualizar o valor, a JVM usa internamente o mecanismo CAS subjacente e tenta atualizar o valor. Se a ...
Qual é a maneira recomendada de esperar até que os futuros threads concluíveis terminem
estou usandoCompletableFuture como mostrado abaixo no código. Mas com relação à maneira como devo esperar até que todas as executáveis terminem, encontrei duas maneiras e não sei a diferença entre elas e qual é a melhor prática? Eles são ...
Usando vários threads para imprimir instruções sequencialmente
Estou tentando imprimir números de 1 a 10 usando três threads. a linha 1 imprime 1, 2 imprime 2, 3 imprime 3, 4 é impressa pela linha 1 novamente e assim por diante. Eu criei um recurso de impressora compartilhada que ajuda esses tópicos ...