Resultados de la búsqueda a petición "parallel-processing"
Escribir un ciclo paralelo
Estoy tratando de ejecutar un bucle paralelo en un ejemplo simple. ¿Qué estoy haciendo mal? from joblib import Parallel, delayed import multiprocessing def processInput(i): return i * i if __name__ == '__main__': # what are your inputs, and ...
Algoritmo de compactación de flujo CUDA
Estoy tratando de construir un algoritmo paralelo con CUDA que tome una matriz de enteros y elimine todos los0Es con o sin mantener el orden. Ejemplo: Memoria global: {0, 0, 0, 0, 14, 0, 0, 17, 0, 0, 0, 0, 13} Resultado de la memoria del host: ...
Java: Paralelización de ordenación rápida a través de subprocesos múltiples
Estoy experimentando con algoritmos de paralelización en Java. Comencé con un tipo de fusión y publiqué mi intento en estepregunta [https://stackoverflow.com/questions/2879955/parallel-processing-via-multithreading-in-java] . Mi intento revisado ...
En Apache Spark, ¿puedo repetir / anidar fácilmente un SparkContext.parallelize?
Estoy tratando de modelar un problema genético que estamos tratando de resolver, construyéndolo en pasos. Puedo ejecutar con éxito los ejemplos de PiAverage de Spark Ejemplos. Ese ejemplo "lanza dardos" en un círculo (10 ^ 6 en nuestro caso) y ...
¿Por qué el flujo paralelo de Files.list () funciona mucho más lento que con Collection.parallelStream ()?
El siguiente fragmento de código es parte de un método que obtiene un listado de directorio, llama a un método de extracción en cada archivo y serializa el objeto de fármaco resultante a xml. try(Stream<Path> paths = Files.list(infoDir)) { paths ...
¿Paralelismo de anidamiento en Spark? ¿Cuál es el enfoque correcto?
¿PARALELIZACIONES ANIDADAS? Digamos que estoy tratando de hacer el equivalente a "anidado para bucles" en Spark. Algo así como en un lenguaje normal, digamos que tengo una rutina en el ciclo interno que estima la forma de Piel ejemplo Pi Average ...
¿Cómo puedo leer mensajes de una cola en paralelo?
SituaciónTenemos una cola de mensajes. Nos gustaría procesar mensajes en paralelo y limitar el número de mensajes procesados simultáneamente. Nuestro código de prueba a continuación procesa los mensajes en paralelo, pero solo inicia un nuevo ...
MPI_Gather 2D array
N es 4, también lo esN_glob. Resulta ser del mismo tamaño.p es 4. Aquí hay una pequeña porción del código: float **global_grid; float **gridPtr; lengthSubN = N/pSqrt; subN = lengthSubN + 2; grid = allocate2D(grid, subN, subN); .. ...
¿Cuál es la diferencia entre programación asincrónica y multihilo?
Pensé que eran básicamente lo mismo: escribir programas que dividieran las tareas entre procesadores (en máquinas que tienen más de 2 procesadores). Entonces estoy ...
¿Por qué este código paralelo es más lento que su versión similar no paralela?
Tengo el siguiente código (copiado aquí de LINQPad). Obviamente parece que no entiendo cómo funciona TPL o que el código es basura, ¿por qué la versión paralela se ejecuta más lentamente que su contraparte no paralela? for (int i = 0; i < 100; ...