Resultados de la búsqueda a petición "concurrency"
Listar la secuencia <Future> to Future <List>
Estoy tratando de convertirList<CompletableFuture<X>> aCompletableFuture<List<T>>. Esto es bastante útil como cuando tiene muchas tareas asincrónicas y necesita obtener resultados de todas ellas. Si alguno de ellos falla, el futuro final falla. ...
ReentrantLock no da el resultado esperado
He creado un programa de consumidores productores usando la función de hilos (esperar y notificar). El código es - /** * Message.java ( Common object ) */ package threads; import java.util.concurrent.locks.ReentrantLock; /** * @author chouhan_r ...
Problema de mónada STM
Este es solo un escenario hipotético para ilustrar mi pregunta. Supongamos que hay dos hilos y un TVar compartido entre ellos. En un hilo hay un bloque atómico que lee el TVar y tarda 10 segundos en completarse. En otro hilo hay un bloque atómico ...
¿Cuándo debo usar un CompletionService sobre un ExecutorService?
Acabo de encontrar CompletionService enesta publicación de blog [http://www.chrisellsworth.com/blogs/devblog/archive/2006/10/31/Java-Concurrency-API-Example.aspx] . Sin embargo, esto realmente no muestra las ventajas de CompletionService sobre un ...
Lista de procesos de elementos 'N' con múltiples hilos
yo tengoList deN artículos y quiero dividir estoList de manera secuencial entre un número fijo dethreads. Por secuencial quiero decir, quiero pasar1 to N/4primerothread , N/4 + 1 to N/2al segundo hilo yN/2+1 to N a la tercerathread, Ahora una ...
Procesamiento concurrente utilizando Stanford CoreNLP (3.5.2)
Estoy enfrentando un problema de concurrencia al anotar múltiples oraciones simultáneamente. No me queda claro si estoy haciendo algo mal o tal vez hay un error en CoreNLP. Mi objetivo es anotar oraciones con la tubería "tokenize, ssplit, pos, ...
¿Cuál es la forma recomendada de esperar hasta que terminen los subprocesos futuros Completables?
estoy usandoCompletableFuture como se muestra a continuación en el código. Pero con respecto a la forma en que debo esperar hasta que terminen todas las carreras, encontré dos formas y no sé la diferencia entre ellas y cuál es la mejor práctica. ...
Cómo LongAdder funciona mejor que AtomicLong
Veo cómo funciona AtomicInteger de Java internamente con la operación CAS (Comparar e intercambiar). Básicamente, cuando varios subprocesos intentan actualizar el valor, JVM usa internamente el mecanismo CAS subyacente e intenta actualizar el ...
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 ...
c # async espera implementación [cerrado]
Tengo algunas dudas sobre el diseño de la próxima función asíncrona / espera de C #. La conveniencia de adjuntar el nuevo mecanismo aTask<T>Creo que es mejor usar asíncrono sustituyendo la palabra clave de espera. Para expaple:var result = async ...