Resultados da pesquisa a pedido "java.util.concurrent"
CompletableFuture não está sendo executado. Se eu usar o pool ExecutorService, seu trabalho conforme o esperado, mas não com o pool comum forkJoin padrão
Eu estou tentando executar a seguinte classe está sendo finalizada sem executar o CompletableFuture. public class ThenApplyExample { public static void main(String[] args) throws Exception { //ExecutorService es = ...
coletando do fluxo paralelo em java 8
Eu quero pegar uma entrada e aplicar fluxo paralelo nisso, então eu quero saída como lista. Entrada pode ser qualquer lista ou coleção na qual podemos aplicar fluxos. Minhas preocupações aqui é que, se queremos que a saída seja mapeada, temos ...
Qual é a razão por trás da implementação do método "get" do AtomicMarkableReference em java?
Em java umAtomicMarkableReference pode ser usado para atualizar atomicamente uma referência de objeto junto com um bit de ...
Quantos threads são gerados no parallelStream no Java 8?
No JDK8, quantos threads são gerados quando estou usando o paralelStream? Por exemplo, no código: list.parallelStream().forEach(/** Do Something */);Se esta lista tiver 100000 itens, quantos threads serão gerados? Além disso, cada um dos ...
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 ...
scala.concurrent.blocking - o que realmente faz?
Passei um tempo aprendendo o tópico dos contextos de execução do Scala, modelos de encadeamento subjacentes e simultaneidade. Você pode explicar de que maneirascala.concurrent.blocking "ajusta o comportamento do tempo de execução" e"pode melhorar ...
AtomicBoolean, defina o sinalizador uma vez, necessário? Um booleano estático pode estar bem?
Estou definindo um sinalizador que é definido uma vez por qualquer thread que possa configurá-lo. Todos os outros threads lerão várias vezes esse sinalizador repetidamente várias vezes. No momento, estou usando um AtomicBoolean, que funciona ...
Java 8: loop FOR paralelo
Ouvi dizer que o Java 8 fornece muitos utilitários em relação à computação simultânea. Portanto, eu estou querendo saber qual é a maneira mais simples de paralelizar o loop for dado? public static void main(String[] args) { Set<Server> servers = ...
ConcurrentHashMap jdk 8 Usa TreeNodes em vez de List .. Por quê? [fechadas]
Oi eu sei o funcionamento deConcurrentHashMap antes do JDK 8. Eu também entendi o código: era bastante modular e não muito difícil de entender. O código deConcurrentHashMap no JDK 8 mudou muito em relação às implementações anteriores. Como essa ...
AGUARDANDO no sun.misc.Unsafe.park (Método Nativo)
Um dos meus aplicativos trava sob algum período de execução sob carga, alguém sabe o que poderia causar essa saída no jstack: "scheduler-5" prio=10 tid=0x00007f49481d0000 nid=0x2061 waiting on condition [0x00007f494e8d0000] ...