Concurrencia

[katerinadobreva]

Hola, he creado tres procesos hijos utilizando fork. Guardo los pid de los procesos hijos en un array llamado p. Los procesos hijos deben ejecutar la misma función de forma infinita. Solo consigo que el primer hijo ejecute la función de forma infinita. ¿Cómo podría hacer que los demás hijos también la ejecutasen? Gracias de antemano.

Código:

if(padre)
{
   for(i=0; i<HIJOS; i++)
   {
      if(p[i])
      {
         for(;;)
         {
            funcion();
         }
      }
   }
}

[eferion]

yo ahí no veo ningún fork y dado que no soy mago ni vidente no puedo adivinar el diseño de tu algoritmo... ¿tanto cuesta poner ejemplos completos?

[katerinadobreva]

Este es el código con fork:

Código:

for(i=0; i<HIJOS && padre; i++)
{
   if((padre = fork()) == -1)
   {
      exit(EXIT_FAILURE);
   }
   else
   {
      p[i] = padre;
   }
}

if(padre)
{ 
   for(i=0; i<HIJOS; i++)
   {
       if(p[i])
       {
          for(;;)
          {
              funcion();
          }
       }
   }
}
else
{
}

[eferion]

Código C:

for(i=0;i<2;i++)
  fork();
 

Pregunta: ¿Cuántos hilos habrá al terminar ese bucle?

Respuesta: 4

Explicación:

• En la primera iteración tendremos dos, el padre (P) y un hijo (H1)
• En la segunda iteración tendremos 4 ( P crea 1 y H1 crea otro)

Luego tu intento de crear únicamente N hijos no funciona porque estás creando un número de hijos desproporcionado.

Por otro lado, llamar a fork hace que el hijo tenga una copia de la memoria del padre y a partir de ese momento cada uno usa su propia memoria... almacenar en un arreglo los id no parece una buena idea porque cada proceso va a almacenar un arreglo diferente.

Si el número de hijos es una constante puedes probar algo tal que:

Código C:

if( fork() ) 
  if( fork() )
    if( fork() )
      return; // Aqui solo llega el padre
 
funcion(); // Los 3 hijos ejecutan esto
 

También puedes embeber el código en un bucle... pero teniendo cuidado de crear procesos únicamente desde el padre:

Código C:

#define HIJOS 3
int main()
{
  int padre = getpid();
 
  for( int i=0;i<HIJOS;i++)
    if( !fork() ) break;
 
  if( getppid() == padre ) // Si el padre del proceso actual es el proceso principal estamos tratando con un hijo
    printf("1");
}
 

Un saludo.

[katerinadobreva]

Ahora se crean bien los procesos hijos. El problema es que al ejecutar la función de forma infinita, el primer proceso entra en el bucle infinito y los demás procesos mueren. Así lo tengo ahora:

Código:

padre = getpid();
for(i=0; i<HIJOS; i++)
{
   if(!fork())
   {
      break;
   }
}
if(getppid() == padre) // Hijos.
{
   for(;;)
   {
      funcion();
   }
}

[eferion]

Si yo ejecuto esto:

Código C:

#define HIJOS 3
 
int main()
{
  int padre = getpid();
  printf("%d <- principal\n", padre);
 
  for(int i=0; i<HIJOS; i++)
  {
    if(!fork())
    {
      break;
    }
  }
  if(getppid() == padre) // Hijos.
  {
    printf("%d <- hijo\n",getpid());
  }
}
 

Obtengo esto:

Código BASH:

29387 <- principal
29389 <- hijo
29387 <- principal
29387 <- principal
29390 <- hijo
29387 <- principal
29391 <- hijo
 

Es decir, en el if únicamente entran los procesos hijos.

Salvo que estés creando otros procesos antes de llegar aquí no se me ocurre cómo te puede estar fallando.

[katerinadobreva]

Sí, el problema es cuando ejecuto la función con el bucle infinito. Es que esa función deben ejecutarla todos los procesos a la vez de forma infinita, pero solo me deja que la ejecute el primero.

[eferion]

¿Es esto acaso una práctica de clase o tu proyecto tiene una utilidad real?

Si es lo segundo posiblemente sea mejor pasar de fork y usar hilos.

En cualquier caso has de tener en cuenta las limitaciones del SO que uses. También has de tener en cuenta que no es lo mismo que el hilo o proceso se ejecute a nivel de SO que a nivel de aplicación. En el segundo caso un hilo que entre en un bucle sin fin puede dejar bloqueados a todos los demás.

[katerinadobreva]

Es para una práctica de clase. ¿Habría otra forma de que se ejecutase todo el rato una función sin utilizar un bucle infinito? Para que no se bloqueasen los demás procesos.

[aguml]

Iniciado por katerinadobreva

Es para una práctica de clase. ¿Habría otra forma de que se ejecutase todo el rato una función sin utilizar un bucle infinito? Para que no se bloqueasen los demás procesos.

Una forma que suelo usar aunque supongo que no será lo más correcto es poner dentro de ese bucle un Sleep (100) por ejemplo. Eso hace que se pause el bucle 100 milisegundos y consigues que no se bloquee.
También depende mucho de lo que haga la función que esta dentro del bucle ya que si lo que esperas en el bucle es algún mensaje o evento quizás podrías usar hilos y esperar la respuesta lo que dejaría al hilo que espera la respuesta congelado a la espera de dicha respuesta. Con eso tampoco dejarías congelado el proceso. También podrías usar una función callback y desde la función que se ejecuta en tu caso envías un mensaje al proceso y lo gestionas sin más. Pipes, memoria compartida sockets y no se que más.