[ncw2233]

Hola he estado tratando de comprender las diferencias entre los fork y los theread en python :
y entiendo lo siguiente :

-Thread son hilos de un proceso que comparten memoria
- fork , son clones o copias de un proceso

lo que yo intento hacer es varios fork para un proceso y eh visto este pequeño script (fuente :http://goo.gl/kwkXC ) al cual le he agregado un random .. pero no ocurre el random ._.
es decir creo los 7 fork y me devuelve lo mismo , eso me da la siguiente duda "random no es tan random xD" o los fork comparten variables. tambien puede ser que no comprenda algun detalle de los fork ,

de ante mano gracias.

Código Python:

Ver original
#! /usr/bin/python
import os
import random
def child():
   print 'A new child ',  os.getpid( )
   print random.random()
   print random.randrange(0, 101, 2)
   os._exit(0)
 
def parent():
   i=0
   while True:
      newpid = os.fork()
      if newpid == 0:
         child()
      else:
         pids = (os.getpid(), newpid)
         print "parent: %d, child: %d" % pids
      if  i== 7:
        break
      i=i+1
 
parent()
 

resultados :

Código BASH:

Ver original
-parent: 8836, child: 8837
A new child  8837
0.773740529819
parent: 8836, child: 8838
42
parent: 8836, child: 8839
A new child  8839
0.773740529819
parent: 8836, child: 8840
42
parent: 8836, child: 8841
A new child  8840
parent: 8836, child: 8842
0.773740529819
42
parent: 8836, child: 8843
A new child  8842
parent: 8836, child: 8844
0.773740529819
42
A new child  8844
0.773740529819
42
A new child  8843
0.773740529819
42
A new child  8841
0.773740529819
42
A new child  8838
0.773740529819
42
 

[razpeitia]

Ejemplo 1: ¿Como usar fork?

Código Python:

Ver original
import os
pid = os.fork()
print pid
 

¿Que esta pasando aquí? Yo solamente puse un print ¿por que imprime 2 veces?
Una vez que llega a os.fork() el programa se divide en 2 flujos el flujo del padre y el flujo del hijo. El padre tiene un pid diferente de 0, mientras que el hijo tiene pid 0.

Ejemplo 2: ¿Como saber quien es el hijo y quien el padre?

Código Python:

Ver original
import os
pid = os.fork()
if pid == 0:
    print "Hijo:", pid
else:
    print "Padre:", pid
 

Ejemplo 3: Los hijos también pueden ser padres.

Código Python:

Ver original
import os
pid = os.fork()
if pid == 0:
    print "Hijo:", pid, os.getpid()
    pid = os.fork()
    if pid == 0:
        print "    Hijo:", pid, os.getpid()
    else:
        print "    Padre:", pid, os.getpid()
else:
    print "Padre:", pid, os.getpid()
 

Donde pid indica el pid del hijo y os.getpid() es el pid del proceso que esta corriendo.


Ejemplo 4: Esperar a que un hijo termine

Código Python:

Ver original
import os
from time import sleep
 
child_pid = os.fork()
 
if child_pid == 0:
    print "Hijo Iniciando"
    sleep(2)
    print "Hijo Trabajando 1, 2, 3..."
    sleep(2)
    print "Hijo Terminado"
    os._exit(0)
else:
    print "Padre Iniciado"
    os.waitpid(child_pid, 0)
    print "Padre Terminado"
 

Ejemplo 6: Múltiples hijos

Código Python:

Ver original
import os
from time import sleep
 
NUM_PROCESS = 7
 
children = []
 
print "Padre Iniciado"
 
for i in range(NUM_PROCESS):
    child_pid = os.fork()
    if child_pid:
        children.append(child_pid)
    else:
        sleep(1)
        print "Child %d" % (i,)
        os._exit(0)
 
for child in children:
    os.waitpid(child, 0)
print "Padre Terminado"
 

Ejemplo 7: Random

Código Python:

Ver original
import os
import random
 
NUM_PROCESS = 7
 
children = []
 
print "Padre Iniciado"
 
for i in range(NUM_PROCESS):
    child_pid = os.fork()
    if child_pid:
        children.append(child_pid)
    else:
        random.seed()
        print "Child %d %d" % (i, random.randrange(0, 101, 2))
        os._exit(0)
 
for child in children:
    os.waitpid(child, 0)
print "Padre Terminado"
 

Recuerdas que un fork es una copia del proceso verdad? Bueno, esa copia también incluye la semilla cuando haces el import random, entonces todos los forks tienen la misma semilla y si todos los forks tienen la misma semilla y usan el mismo algoritmo entonces obviamente te va a dar los mismo números. La solución a esto es reestablecer la semilla en cada proceso hijo.

[ncw2233]

razpeitia , exelente maestro , con esa repuesta me ha quedado mas que claro el tema de como funciona un fork ,
pero sabes que : me queda un asuntillo con el tema del waitpid :
- En tu ejemplo 4,5,6 ¿ el waitpid , sirve para controlar el cierre del pid padre ? .

De ante mano muchas gracias . y los ejemplos estan exelentisimos para aprender.
Saludos.

[razpeitia]

En los ejemplos waitpid es para que el proceso padre espere a que sus hijos terminen.

Obviamente los procesos hijos no llegan a correr el bloque final de los ejemplos 6 y 7 por que os._exit es ejecutado antes. La diferencia de os.exit y os._exit es que os._exit es para los procesos hijos.

Por ultimo si vas hacer uso de procesos para asuntos de concurrencia, entonces te recomiendo que manejes multiprocessing, que es mucho mas cómodo para trabajar.

[ncw2233]

ok , me quedo super claro .
Nuevamente muchas gracias.
revisare el link :D
Saludos.

Cita:

Iniciado por razpeitia

En los ejemplos waitpid es para que el proceso padre espere a que sus hijos terminen.

Obviamente los procesos hijos no llegan a correr el bloque final de los ejemplos 6 y 7 por que os._exit es ejecutado antes. La diferencia de os.exit y os._exit es que os._exit es para los procesos hijos.

Por ultimo si vas hacer uso de procesos para asuntos de concurrencia, entonces te recomiendo que manejes [URL="http://docs.python.org/2/library/multiprocessing.html"]multiprocessing[/URL], que es mucho mas cómodo para trabajar.