Resultados de la búsqueda a petición "parallel-processing"
Problema con Invoke para paralelizar foreach
Tengo un problema con el uso de System.Threading.Tasks.Parallel.ForEach. El cuerpo para cada barra de progreso quiere actualizar. Pero el método de invocación a veces se congela. Adjunto el código al formulario que es prograssbar y ...
R paralela con foreach y mclapply al mismo tiempo
Estoy implementando un sistema de procesamiento paralelo que eventualmente se implementará en un clúster, pero tengo problemas para determinar cómo interactúan los diversos métodos de procesamiento paralelo. Necesito usar un bucle for para ...
iterador de manupulación en mapreduce
Estoy tratando de encontrar la suma de cualquier punto dado usando hadoop. El problema que tengo es obtener todos los valores de una clave dada en un solo reductor. Se parece a esto. Reductor: public static class Reduce extends MapReduceBase ...
No estoy seguro de cómo explicar algunos de los resultados de rendimiento de mi código de multiplicación de matriz paralela
Estoy ejecutando este código en OpenMP para la multiplicación de matrices y medí sus resultados: #pragma omp for schedule(static) for (int j = 0; j < COLUMNS; j++) for (int k = 0; k < COLUMNS; k++) for (int i = 0; i < ROWS; i++) matrix_r[i][j] ...
operación rowwise con dplyr
Estoy trabajando en un gran marco de datos en R de 2,3 millones de registros que contienen transacciones de usuarios en ubicaciones con tiempos de inicio y finalización. Mi objetivo es crear un nuevo marco de datos que contenga la cantidad de ...
procesamiento paralelo con flujo infinito en Java
¿Por qué el siguiente código no imprime ninguna salida, mientras que si eliminamos el paralelo, imprime 0, 1? IntStream.iterate(0, i -> ( i + 1 ) % 2) .parallel() .distinct() .limit(10) .forEach(System.out::println);Aunque lo ideal es que el ...
Múltiples hilos leyendo desde el mismo archivo
Tengo un archivo xml que necesita ser leído muchas veces. Estoy tratando de usar Parallel.ForEach para acelerar este proceso, ya que ninguno de los datos que se leen es relevante en cuanto al orden en que se leen. Los datos solo se ...
numba guvectorize target = 'paralelo' más lento que target = 'cpu'
Intenté optimizar un fragmento de código de Python que involucra grandes cálculos de matriz multidimensional. Estoy obteniendo resultados contraintuitivos con numba. Estoy ejecutando un MBP, a mediados de 2015, i7 quadcore de 2.5 GHz, OS 10.10.5, ...
Futuros en Haskell
¿Haskell tiene un equivalente de la capacidad de Alice para vincular una variable a un futuro? val a = spawn foo;donde foo es alguna función. Sé que Haskell admite canales e hilos; Espero una sintaxis tan natural como la de Alice para vincular ...
Cómo optimizar el código de multiplicación matricial (matmul) para que se ejecute rápidamente en un solo núcleo de procesador
Estoy trabajando en conceptos de programación paralela y tratando de optimizar el ejemplo de multiplicación de matrices en un solo núcleo. La implementación más rápida que se me ocurrió hasta ahora es la siguiente: /* This routine performs a ...