Discussion :

[lea.soineca]

Est-il possible d'utiliser des pthread au lieu d'un fork, pour le code suivant ?

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
#include <stdio.h>
  #include <memory.h>
  #include <unistd.h>
 
  int main( int argc, char ** argv )
  {
   /* create the pipe */
   int pfd[2];
   if (pipe(pfd) == -1)
     {
       printf("pipe failed\n");
       return 1;
     }
 
   /* create the child */
   int pid;
   if ((pid = fork()) < 0)
     {
       printf("fork failed\n");
       return 2;
     }
 
   if (pid == 0)
     {
       /* child */
       close(pfd[1]); /* close the unused write side */
       dup2(pfd[0], 0); /* connect the read side with stdin */
       close(pfd[0]); /* close the read side */
       /* execute the process (wc command) */
       execlp("wc", "wc", (char *) 0);
       printf("wc failed"); /* if execlp returns, it's an error */
       return 3;
     }
   else
     {
       /* parent */
       close(pfd[0]); /* close the unused read side */
       dup2(pfd[1], 1); /* connect the write side with stdout */
       close(pfd[1]); /* close the write side */
       /* execute the process (ls command) */
       execlp("ls", "ls", (char *)0);
       printf("ls failed"); /* if execlp returns, it's an error */
       return 4;
     }
   return 0;
  }

J'ai essayé, en mettant les flux en argument. Mais lorsque je ferme l'écriture ou la lecture d'un flux dans un thread, cela le ferme aussi pour l'autre thread...
Donc cela ne fonctionne pas.

Comment peut-on faire?

[dinobogan]

Tu peux sans problème utiliser des threads au lieu de processus séparés.
Par contre, tu ne dois pas fermer la lecture pour l'émetteur et l'écriture pour le lecteur avant de commencer puisque le tableau à 2 descripteurs est partagé par les 2 threads. Globalement, tu n'as plus deux tableaux mais un seul, partagé.

Ton problème vient probablement du manque de compréhension sur le fork : ton tableau de descripteurs est dupliqué dans les 2 processus. Chaque processus possède un tableau à 2 descripteurs, un seul descripteur sera utile pour chaque processus. Celui qui est inutile est fermé.
Par contre, dans l'usage des threads, tu as un seul processus, un seul tableau à 2 descripteurs. Les 2 threads accèdent aux 2 descripteurs. Il n'y a aucun descripteur inutile.

[lea.soineca]

Ok mais cela ne fonctionne pas.

Voici ma transformation :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
#include <stdio.h>
#include <memory.h>
#include <unistd.h>
#include <pthread.h>
 
void * child(void * pfds) {
	int * pfd = pfds;
 
	//close(pfd[1]); /* close the unused write side */
	dup2(pfd[0], 0); /* connect the read side with stdin */
	//close(pfd[0]); /* close the read side */
	/* execute the process (wc command) */
	execlp("wc", "wc", (char *) 0);
	printf("wc failed"); /* if execlp returns, it's an error */
}
 
void * parent(void * pfds) {
	int * pfd = pfds;
 
	//close(pfd[0]); /* close the unused read side */
	dup2(pfd[1], 1); /* connect the write side with stdout */
	//close(pfd[1]); /* close the write side */
	/* execute the process (ls command) */
	execlp("ls", "ls", (char *)0);
	printf("ls failed"); /* if execlp returns, it's an error */
}
 
int main( int argc, char ** argv )
{
	/* create the pipe */
	int pfd[2];
	if (pipe(pfd) == -1)
	{
		printf("pipe failed\n");
		return 1;
	}
 
	pthread_t t1, t2;
	pthread_create(&t1, NULL, child, pfd);
	pthread_create(&t2, NULL, parent, pfd);
 
	pthread_join(t1, NULL);
	pthread_join(t2, NULL);
 
	return 0;
}

Rien ne s'affiche....

[dinobogan]

execlp remplace le processus courant. Tu ne peux pas l'utiliser dans ce cas puisque tu veux que ton programme courant se termine.
Tu devrais utiliser popen. Mais du coup le tableau de descripteur devient inutile.

[lea.soineca]

Je n'ai pas très bien compris.

Tu ne peux pas l'utiliser dans ce cas puisque tu veux que ton programme courant se termine.

Pourquoi, je ne peux pas utiliser execlp ?
Et pourquoi mon programme ne se terminerait pas ?

[dinobogan]

Va lire la documentation sur execlp.
Pour résumé très brièvement, execlp remplace le processus courant par un autre processus construit depuis ses arguments. Ton programme est remplacer par "wc" ou par "ls", selon le thread le plus rapide.
Dans ton programme multi-thread, tu ne peux pas utiliser execlp.