He creado una funcion que hace un ping a las IP que le pase por parametro
Por ejemplo:
funcPing (10, [0, 256], 10 , 10) #tarda 10 seg en ser ejecutada y hace ping a todas las ips de tipo 10.X.10.10
funcPing (192, 168, [0, 10], [0, 256]) #tarda 60 segundos en ser ejecutada y hace ping a todas las ips tipo 192.168.0-10.X
Decir que el tiempo no viene determinado por una funcion time si no que depende de la cantidad de operaciones que realiza internamente y que puedo separar la llamada a la funcion de la siguiente manera.
funcPing (192, 168, [0, 10], [0, 256]) puede ser fragmentada en
- funcPing (192, 168, [0, 6], [0, 256]) tarda 30 seg
- funcPing (192, 168, [6, 10], [0, 256]) tarda 30 seg
Cual seria la mejor manera de paralelizar el codigo de tal modo que tarde lo menos posible sin tener que estar calculando cuantos hilos necesita cada tarea
Lo he intentado de las 2 siguientes maneras pero en ambos casos, he tenido que calcular a mano cuantos hilos necesita. Ademas, me gustaria saber si es posible hacer que cuando finalice un hilo, este se ponga a ejecutar las operaciones que los otros hilos aun no han podido ejecutar
with ThreadPoolExecutor() as executor:
executor.submit(ping, 10, [0, 256], 10 , 10)
executor.submit(ping, 192, 168, [0, 6], [0, 256])
executor.submit(ping, 192, 168, [6, 10], [0, 256])
Y tambien
t1 = threading.Thread(target=ping,args=(10, [0, 256], 10 , 10)
t2 = threading.Thread(target=ping,args=(192, 168, [0, 6], [0, 256])
t3 = threading.Thread(target=ping,args=(192, 168, [6, 10], [0, 256])
t1.start()
t2.start()
t3.start()
t1.join()
t2.join()
t3.join()
¿Existe alguna funcionalidad donde yo espeficique el numero de hilos a utilizar y las llamadas a funciones y esta las optimice?