Skip to main content
Correcciones gramticales
Origen Enlace
FJSevilla
  • 62.1k
  • 7
  • 43
  • 68

En este caso la operación no es atómica, por lo que puede quedar interrumpida a medias provocando condiciones de carrera entre los hilos. Un hilo podría intentar leer o asignar un nuevo valor antes de que el nuevo valor se asigne por el otro hilo, resultado: vete a saber, porque además con los hilos, al contrario que con las corrutinas, no tienes nunca el control de cuando se salta de un hilo a otro.

Lo mejor, no usar variables globales compartidas entre los hilos, sino usar mecanismos seguros de comunicación como son las colas. Si aún así quieres usar una variable global, usa un mecanismo de sincronización entre los hilos para evitar condiciones de carrera en operaciones no atómicas, un simple candado basta en este caso.

Seguramente te preguntarás ¿por qué no ocurría esto con números menores? Pues por suerte, la operación es tan insignificante que no se salta de un hilo a otro por olo que no hay condiciones de carrera.

Ya te digo que no vas a ganar tiempo de ejecución así, al contrario. Python tiene una limitación en cuanto a los hilos por culpa del GIL, en esencia los hilos permiten concurrencia pero no paralelismo, dado que solo un hilo puede ejecutarse al mismo tiempo en un intérprete. Lo cual reduce su utilidad a cuando el problema es un problema de tipo I/O, pero no aportan nada cuando el problema es de computación. El GIL puede ser liberado en extensiones viavía C-Python API, con Cython, etc (NumPy por ejemplo lo hace), pero si no, debes usar multiprocesos si quieres paralelismo real.

No tiene nada que ver con el error, pero no uses sum como nombre para una variable o función. sum es una función builtin de Python y al hacer lo anterior la solapas, lo cual pude causar errores si se usa en otras partes del código o, como mínimo, es confuso para quién lelee el código.

Así mismo, usar time o datetime para medir tiempos de ejecución no es nada preciso, solo te puede valer como referencia. Para éstas cosas tiene seltienes el módulo timeit.

En este caso la operación no es atómica, por lo que puede quedar interrumpida a medias provocando condiciones de carrera entre los hilos. Un hilo podría intentar leer o asignar un nuevo valor antes de que el nuevo valor se asigne por el otro hilo, resultado: vete a saber, porque además con los hilos al contrario que con las corrutinas no tienes nunca el control de cuando se salta de un hilo a otro.

Lo mejor, no usar variables globales compartidas entre los hilos sino usar mecanismos seguros de comunicación como son las colas. Si aún así quieres usar una variable global usa un mecanismo de sincronización entre los hilos para evitar condiciones de carrera en operaciones no atómicas, un simple candado basta en este caso.

Seguramente te preguntarás ¿por qué no ocurría esto con números menores? Pues por suerte, la operación es tan insignificante que no se salta de un hilo a otro por o que no hay condiciones de carrera.

Ya te digo que no vas a ganar tiempo de ejecución así, al contrario. Python tiene una limitación en cuanto a los hilos por culpa del GIL, en esencia los hilos permiten concurrencia pero no paralelismo, dado que solo un hilo puede ejecutarse al mismo tiempo en un intérprete. Lo cual reduce su utilidad a cuando el problema es un problema de tipo I/O, pero no aportan nada cuando el problema es de computación. El GIL puede ser liberado en extensiones via C-Python API, con Cython, etc (NumPy por ejemplo lo hace), pero si no debes usar multiprocesos si quieres paralelismo real.

No tiene nada que ver con el error, pero no uses sum como nombre para una variable o función. sum es una función builtin de Python y al hacer lo anterior la solapas, lo cual pude causar errores si se usa en otras partes del código o, como mínimo, es confuso para quién le el código.

Así mismo, usar time o datetime para medir tiempos de ejecución no es nada preciso, solo te puede valer como referencia. Para éstas cosas tiene sel módulo timeit.

En este caso la operación no es atómica, por lo que puede quedar interrumpida a medias provocando condiciones de carrera entre los hilos. Un hilo podría intentar leer o asignar un nuevo valor antes de que el nuevo valor se asigne por el otro hilo, resultado: vete a saber, porque además con los hilos, al contrario que con las corrutinas, no tienes nunca el control de cuando se salta de un hilo a otro.

Lo mejor, no usar variables globales compartidas entre los hilos, sino usar mecanismos seguros de comunicación como son las colas. Si aún así quieres usar una variable global, usa un mecanismo de sincronización entre los hilos para evitar condiciones de carrera en operaciones no atómicas, un simple candado basta en este caso.

Seguramente te preguntarás ¿por qué no ocurría esto con números menores? Pues por suerte, la operación es tan insignificante que no se salta de un hilo a otro por lo que no hay condiciones de carrera.

Ya te digo que no vas a ganar tiempo de ejecución así, al contrario. Python tiene una limitación en cuanto a los hilos por culpa del GIL, en esencia los hilos permiten concurrencia pero no paralelismo, dado que solo un hilo puede ejecutarse al mismo tiempo en un intérprete. Lo cual reduce su utilidad a cuando el problema es un problema de tipo I/O, pero no aportan nada cuando el problema es de computación. El GIL puede ser liberado en extensiones vía C-Python API, con Cython, etc (NumPy por ejemplo lo hace), pero si no, debes usar multiprocesos si quieres paralelismo real.

No tiene nada que ver con el error, pero no uses sum como nombre para una variable o función. sum es una función builtin de Python y al hacer lo anterior la solapas, lo cual pude causar errores si se usa en otras partes del código o, como mínimo, es confuso para quién lee el código.

Así mismo, usar time o datetime para medir tiempos de ejecución no es nada preciso, solo te puede valer como referencia. Para éstas cosas tienes el módulo timeit.

se añadieron 462 caracteres en el cuerpo
Origen Enlace
FJSevilla
  • 62.1k
  • 7
  • 43
  • 68

Ya te digo que no vas a ganar tiempo de ejecución así, al contrario. Python tiene una limitación en cuanto a los hilos por culpa del GIL, en esencia los hilos permiten concurrencia pero no paralelismo, dado que solo un hilo puede ejcutarseejecutarse al mismo tiempo en un intérprete. Lo cual reduce su utilidad a cuando el problema es un problema de tipo I/O, pero no aportan nada cuando el problema es de computación. El GIL puede ser liberado en extensiones via C-Python API, con Cython, etc (NumPy por ejemplo lo hace), pero si no debes usar multiprocesos si quieres paralelismo real.

No tiene nada que ver con el error, pero no uses sum como nombre para una variable o función. sum es una función builtin de Python y al hacer lo anterior la solapas, lo cual pude causar errores si se usa en otras partes del código o, como mínimo, es confuso para quién le el código.

Así mismo, usar time o datetime para medir tiempos de ejecución no es nada preciso, solo te puede valer como referencia. Para éstas cosas tiene sel módulo timeit.

Ya te digo que no vas a ganar tiempo de ejecución así, al contrario. Python tiene una limitación en cuanto a los hilos por culpa del GIL, en esencia los hilos permiten concurrencia pero no paralelismo, dado que solo un hilo puede ejcutarse al mismo tiempo en un intérprete. Lo cual reduce su utilidad a cuando el problema es un problema de tipo I/O, pero no aportan nada cuando el problema es de computación. El GIL puede ser liberado en extensiones via C-Python API por ejemplo, pero si no debes usar multiprocesos si quieres paralelismo real.

Ya te digo que no vas a ganar tiempo de ejecución así, al contrario. Python tiene una limitación en cuanto a los hilos por culpa del GIL, en esencia los hilos permiten concurrencia pero no paralelismo, dado que solo un hilo puede ejecutarse al mismo tiempo en un intérprete. Lo cual reduce su utilidad a cuando el problema es un problema de tipo I/O, pero no aportan nada cuando el problema es de computación. El GIL puede ser liberado en extensiones via C-Python API, con Cython, etc (NumPy por ejemplo lo hace), pero si no debes usar multiprocesos si quieres paralelismo real.

No tiene nada que ver con el error, pero no uses sum como nombre para una variable o función. sum es una función builtin de Python y al hacer lo anterior la solapas, lo cual pude causar errores si se usa en otras partes del código o, como mínimo, es confuso para quién le el código.

Así mismo, usar time o datetime para medir tiempos de ejecución no es nada preciso, solo te puede valer como referencia. Para éstas cosas tiene sel módulo timeit.

Origen Enlace
FJSevilla
  • 62.1k
  • 7
  • 43
  • 68

Tienes dos errores muy propios de la programación concurrente:

  • Asumes que el incremento de la variable suma (suma += lista[i]) es una operación atómica cuando no lo es.

Pero primero, atómico significa que la operación es indivisible e irreductible, debe realizarse en su totalidad una vez iniciada o no se realiza, pero no puede quedar a medias. Esto implica que en medio de la operación el SO no puede decidir que le vendría bien que el procesador deje esa operación en ese hilo aparcada y haga otra cosita que le parece más urgente.

En este caso la operación no es atómica, por lo que puede quedar interrumpida a medias provocando condiciones de carrera entre los hilos. Un hilo podría intentar leer o asignar un nuevo valor antes de que el nuevo valor se asigne por el otro hilo, resultado: vete a saber, porque además con los hilos al contrario que con las corrutinas no tienes nunca el control de cuando se salta de un hilo a otro.

Lo mejor, no usar variables globales compartidas entre los hilos sino usar mecanismos seguros de comunicación como son las colas. Si aún así quieres usar una variable global usa un mecanismo de sincronización entre los hilos para evitar condiciones de carrera en operaciones no atómicas, un simple candado basta en este caso.

  • El segundo error es que simplemente no esperas a que los hilos terminen par imprimir el resultado, por lo que imprimes cuando la suma no se ha completado. Para que el hilo principal espere a que los hijos terminen usa join.

import threading
import numpy as np

suma = 0
lock = threading.Lock()

def sumatoria(lista, inicio, fin):
    global suma
    for i in range(inicio, fin):
        lock.acquire()
        suma += lista[i]
        lock.release()

def sumatoria2(lista, inicio, fin):
     suma = 0
     for i in range(inicio, fin):
        suma += lista[i]
     return suma


lista = np.arange(100000, dtype=int)

t1 = threading.Thread(
    name="hilo1", target=sumatoria,
    args=[lista, 0, int((len(lista)/2))]
    )

t2 = threading.Thread(
    name="hilo2", target=sumatoria,
    args=[lista, int(len(lista)/2), len(lista)]
    )

t1.start()
t2.start()
t1.join()
t2.join()

print("Suma con hilos: ", suma)
print("Suma sin hilos: ", lista.sum())

Seguramente te preguntarás ¿por qué no ocurría esto con números menores? Pues por suerte, la operación es tan insignificante que no se salta de un hilo a otro por o que no hay condiciones de carrera.

Ya te digo que no vas a ganar tiempo de ejecución así, al contrario. Python tiene una limitación en cuanto a los hilos por culpa del GIL, en esencia los hilos permiten concurrencia pero no paralelismo, dado que solo un hilo puede ejcutarse al mismo tiempo en un intérprete. Lo cual reduce su utilidad a cuando el problema es un problema de tipo I/O, pero no aportan nada cuando el problema es de computación. El GIL puede ser liberado en extensiones via C-Python API por ejemplo, pero si no debes usar multiprocesos si quieres paralelismo real.