Resultados de la búsqueda a petición "concurrency"
Fork Join optimization
Lo que quiero Quiero trabajar en la optimización del algoritmo fork / join. Por optimización me refiero solo al cálculo del número óptimo de hilos, o si lo desea, cálculo deSEQUENTIAL_THRESHOLD (ver código abajo) // PSEUDOCODE Result ...
Acceso concurrente a ArrayList
Estoy consciente deArrayList no es seguro para subprocesos, pero no estoy seguro de las implicaciones exactas de esto. En el caso deThreadA yThreadB ambos usando unArrayList, ¿cuál de estas situaciones causará problemas y necesitará ...
¿Cómo puedo usar parMap con una función monádica?
Tengo una función monádica getRate: getRate :: String -> IO DoubleMe gustaría asignar esta función a una lista de cadenas. Normalmente, solo haría: mapM getRate ["foo", "bar"]pero dado que cada llamada a getRate realiza llamadas de red, me ...
colas de trabajo de productor / consumidor
Estoy luchando con la mejor manera de implementar mi canal de procesamiento. Mis productores alimentan el trabajo a un BlockingQueue. En el lado del consumidor, sondeo la cola, envuelvo lo que obtengo en una tarea Runnable y lo envío a un ...
¿Cómo declarar elementos de matriz volátiles en Java?
¿Hay alguna manera de declarar elementos de matriz?volatile en Java Es decir. volatile int[] a = new int[10];declara elreferencia de matriz volatile, pero elelementos de matriz (p.ej.a[1]) todavía no son volátiles. Entonces estoy buscando algo ...
Corrientes paralelas, colectores y seguridad de roscas.
Vea el ejemplo simple a continuación que cuenta el número de ocurrencias de cada palabra en una lista: Stream<String> words = Stream.of("a", "b", "a", "c"); Map<String, Integer> wordsCount = words.collect(toMap(s -> s, s -> 1, (i, j) -> i + ...
¿Los números primos de Eratóstenes son secuenciales más rápidos que simultáneamente?
Actualmente estoy escribiendo un programa que primero genera números primos por el Tamiz de Eratóstenes secuencialmente, luego concurrentemente. Se supone que la versión concurrente del algoritmo es más rápida que la secuencial, pero en mi caso ...
Lista enlazada simultánea sin bloqueo en Java
Me gustaría usar una lista vinculada como la que se describe enesta [http://reference.kfupm.edu.sa/content/l/o/lock_free_linked_lists_using_compare_and_3368.pdf] papel. Sin embargo, no encontré ninguna implementación de Java en la web. Si no ...
Equivalente del canal de golang en Java
Tengo un requisito donde necesito leer de un conjunto de colas de bloqueo. Las colas de bloqueo son creadas por la Biblioteca que estoy usando. Mi código tiene que leer de las colas. No quiero crear un hilo lector para cada una de estas colas de ...
Implementación elegante de indicadores de longitud de cola para ExecutorServices
¿Por qué? ¿Por qué no?java.util.concurrent proporcionar indicadores de longitud de cola para suExecutorServices? Recientemente me encontré haciendo algo como esto: ExecutorService queue = Executors.newSingleThreadExecutor(); ...