run_processes

 

Descripción

Ejecuta una función dada para una lista de elementos dada en un número dado de procesos

Parámetros

Nombre	Tipo	Requerido	Descripción
max_processes	int	Si	El número máximo de procesos a ejecutar en paralelo
function	callable	SI	La función a ejecutar para cada ítem
items	list	Si	Lista de ítems a procesar
print_errors	bool	No	Si se van a imprimir los errores

Return 

Tipo	Descripción
bool	True si todos los procesos se completaron con éxito, False en caso contrario

Versión

• 1.0.0

import pandoraPluginTools as pt

# Define a function to be executed by parallel processes
def process_data(item):
    result = item * 2
    print(f"Item: {item}, Processed Value: {result}")

# List of items to process
data_list = [1, 2, 3, 4, 5]

# Number of parallel processes to use
num_processes = 2

# Run the function for each item using parallel processes
success = pt.run_processes(max_processes=num_processes, function=process_data, items=data_list, print_errors=True)

if success:
    print("All processes completed successfully.")
else:
    print("Errors occurred during process execution.")