fork o usar Thread

[razpeitia]

Ejemplo 1: ¿Como usar fork?

Código Python:

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:

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:

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:

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:

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:

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.