Mi problema es que no se porque las variables globales numero_mas_frecuente y numero_max_apariciones no se me actualizan. He probado de varias formas pero no consigo solucionarlo, tengo una versión del codigo con hilos en la cual si que se me actualizan. He intentado buscar informacion en Internet pero no he encontrado. El codigo consiste en un programa que crea un archivo txt, en el que por cada linea se escribe un numero aleatorio, y cada proceso tiene que contar el numero que corresponde a su numero de proceso, por ejemplo si es el proceso numero 3, cuenta el numero de 3 del archivo. Solo hay un numero por linea, al final de la ejecucion, se publica el numero que ha aparecido mas veces y el numero de veces que ha aparecido.
import multiprocessing
import random
import time
#Variables globales para almacenar el número más frecuente y su cantidad de apariciones
numero_mas_frecuente = 0
numero_max_apariciones = 0
#Función para el proceso generador
def generador_process(file_name, num_lines, rango):
with open(file_name, 'w') as f:
for _ in range(num_lines):
number = str(random.randint(1, rango))
f.write(number + '\n')
#Función para el proceso contador
def contador_process(file_name, process_num):
global numero_mas_frecuente
global numero_max_apariciones
cuentas = 0
with open(file_name, 'r') as f:
for line in f:
if int(line.strip()) == process_num:
cuentas += 1
print(f"Proceso {process_num}: Número {process_num} apareció {cuentas} veces.") #Esto no tiene que estar con el candado, ya que es un print de variables privadas.
if cuentas > numero_max_apariciones:
numero_mas_frecuente = int(process_num)
numero_max_apariciones = int(cuentas)
#Programa Principal
if __name__ == "__main__":
num_processes = int(input("Introduce el número de procesos: "))
num_lineas = int(input("Introduce el número de líneas del archivo: "))
rango = num_processes
file_name = "numeros.txt"
tiempo_inicial = time.time()
#Crear proceso generador
generador = multiprocessing.Process(target=generador_process, args=(file_name, num_lineas, num_processes))
generador.start()
generador.join()
print(f"El tiempo para generar el archivo son: {time.time() - tiempo_inicial} segundos")
start_time = time.time()
#Crear grupo de procesos contadores
processes = []
for i in range(num_processes):
process = multiprocessing.Process(target=contador_process, args=(file_name, i+1))
processes.append(process)
process.start()
#Esperar a que todos los procesos terminen
for process in processes:
process.join()
print(f"Tiempo empleado para contar: {time.time() - start_time} segundos")
print(f"Número más frecuente: {numero_mas_frecuente}, Contador máximo: {numero_max_apariciones}")