Articles of parallel processing

Mida el tiempo de ejecución en C ++ código OpenMP

Estoy ejecutando un código .cpp (i) en estilo secuencial y (ii) usando declaraciones OpenMP. Estoy tratando de ver la diferencia de tiempo. Para calcular el tiempo, uso esto: #include ….. main() { clock_t start, finish; start = clock(); . . . finish = clock(); processing time = (double(finish-start)/CLOCKS_PER_SEC); } El tiempo es bastante preciso en […]

¿Cómo configurar un grupo de subprocesos afinado para futuros?

¿Qué tan grande es el grupo de hilos de Scala para futuros? Mi aplicación Scala genera muchos millones de future {} s future {} y me pregunto si hay algo que pueda hacer para optimizarlos configurando un grupo de subprocesos. Gracias.

¿Cuál es el estado de la progtwigción multinúcleo en Haskell?

¿Cuál es el estado de la progtwigción multinúcleo en Haskell? ¿Qué proyectos, herramientas y bibliotecas están disponibles ahora? ¿Qué informes de experiencia ha habido?

Capture la salida del proceso generado a cadena

Fondo: Estoy trabajando en un progtwig que debe ser capaz de capturar los valores stdout , stderr y return de un progtwig. Idealmente, me gustaría capturarlos en una cadena que almaceno dentro de mi objeto que contiene detalles del proceso. Actualmente tengo un código que funciona guardando la salida en un archivo usando algunos (en […]

Por qué la secuencia paralela se recostack secuencialmente en Java 8

¿Por qué forEach imprime números en orden aleatorio, mientras que la collect siempre recoge los elementos en el orden original, incluso de la secuencia paralela? Integer[] intArray = {1, 2, 3, 4, 5, 6, 7, 8}; List listOfIntegers = new ArrayList(Arrays.asList(intArray)); System.out.println(“Parallel Stream: “); listOfIntegers .stream() .parallel() .forEach(e -> System.out.print(e + ” “)); System.out.println(); // […]

Comportamiento de stream.skip con operación de terminal desordenada

Ya he leído esto y estas preguntas, pero sigo dudando si el comportamiento observado de Stream.skip fue pensado por los autores de JDK. Tengamos una entrada simple de los números 1..20: List input = IntStream.rangeClosed(1, 20).boxed().collect(Collectors.toList()); Ahora, creemos una secuencia paralela, combine unordered() con skip() de diferentes maneras y recopile el resultado: System.out.println(“skip-skip-unordered-toList: ” + […]

¿Cuál es el propósito de la instrucción “PAUSA” en x86?

Estoy tratando de crear una versión tonta de un locking de giro. Al navegar por la web, encontré una instrucción de ensamble llamada “PAUSE” en x86 que se usa para dar pistas a un procesador de que un spin-lock se está ejecutando actualmente en esta CPU. El manual de Intel y otra información disponible indican […]

¿Java tiene soporte para procesadores multinúcleo / parallel processing?

Sé que ahora que la mayoría de los procesadores tienen dos o más núcleos, la progtwigción multinúcleo es furor. ¿Hay alguna funcionalidad para utilizar esto en Java? Sé que Java tiene una clase Thread, pero también sé que esto fue por mucho tiempo antes de que las multicores se hicieran populares. Si puedo hacer uso […]

Ejecutando varios scripts en script bash paralelo

Tengo un script bash que contiene otros scripts dentro que se ejecutan en serie. Sin embargo, lleva una buena cantidad de tiempo ejecutarlos todos. ¿Hay alguna manera de ejecutar estos scripts en paralelo para mejorar el rendimiento general? Ellos son independientes el uno del otro. Se ve similar a: #!/bin/bash #some code here cppcheck.sh churn.sh […]

Ejecutando un número limitado de procesos hijo en paralelo en bash?

Tengo un gran conjunto de archivos para los cuales es necesario realizar un gran procesamiento. Este procesamiento en una sola hebra, utiliza unos cientos de MiB de RAM (en la máquina utilizada para comenzar el trabajo) y tarda unos minutos en ejecutarse. Mi uso actual es comenzar un trabajo de hadoop en los datos de […]