Resultados de la búsqueda a petición "java.util.concurrent"
CompletableFuture no se está ejecutando. Si uso el grupo ExecutorService, funciona como se esperaba pero no con el grupo común forkJoin predeterminado
Estoy intentando ejecutar la siguiente clase se termina sin ejecutar CompletableFuture. public class ThenApplyExample { public static void main(String[] args) throws Exception { //ExecutorService es = ...
recogiendo de flujo paralelo en java 8
Quiero tomar una entrada y aplicar una transmisión paralela en eso, luego quiero salida como lista. La entrada podría ser cualquier Lista o cualquier colección en la que podamos aplicar transmisiones. Mi preocupación aquí es que si queremos ...
¿Cuál es la razón detrás de la implementación del método "get" de AtomicMarkableReference en java?
En java unAtomicMarkableReference se puede usar para actualizar atómicamente una referencia de objeto junto con un bit de ...
¿Cuántos hilos se generan en parallelStream en Java 8?
En JDK8, ¿cuántos subprocesos se generan cuando estoy usando parallelStream? Por ejemplo, en el código: list.parallelStream().forEach(/** Do Something */);Si esta lista tiene 100000 artículos, ¿cuántos hilos se generarán? Además, ¿cada uno de ...
Usar múltiples hilos para imprimir declaraciones secuencialmente
Estoy tratando de imprimir números del 1 al 10 usando tres hilos. el hilo 1 imprime 1, 2 imprime 2, 3 imprime 3, 4 se imprime por el hilo 1 nuevamente y así sucesivamente. He creado un recurso de impresora compartido que ayuda a esos hilos a ...
scala.concurrent.blocking: ¿qué hace realmente?
He pasado un tiempo aprendiendo el tema de los contextos de ejecución de Scala, los modelos de subprocesos subyacentes y la concurrencia. ¿Puedes explicar de qué manerasscala.concurrent.blocking "ajustar el comportamiento del tiempo de ejecución" ...
AtomicBoolean, establezca la bandera una vez, ¿es necesario? ¿Podría un booleano estático estar bien?
Estoy configurando una bandera que se establece una vez por cualquier hilo que pueda configurarlo. Todos los demás subprocesos leerán esta bandera en varias ocasiones con bastante frecuencia. En este momento estoy usando un AtomicBoolean, que ...
Java 8: ciclo FOR paralelo
Escuché que Java 8 proporciona muchas utilidades con respecto a la computación concurrente. Por lo tanto, me pregunto cuál es la forma más simple de paralelizar el ciclo for dado. public static void main(String[] args) { Set<Server> servers = ...
ConcurrentHashMap jdk 8 utiliza TreeNodes en lugar de List .. ¿Por qué? [cerrado]
Hola, sé el funcionamiento deConcurrentHashMap antes de JDK 8. También entendí el código: era bastante modular y no muy difícil de entender. El código deConcurrentHashMap en JDK 8 ha cambiado mucho desde sus implementaciones anteriores. Debido ...
ESPERANDO en sun.misc.Unsafe.park (Método nativo)
Una de mis aplicaciones se cuelga bajo un período de ejecución bajo carga, ¿alguien sabe qué podría causar tal salida en jstack: "scheduler-5" prio=10 tid=0x00007f49481d0000 nid=0x2061 waiting on condition [0x00007f494e8d0000] ...