thread, fonction et mutex ?

Version imprimable

bonjour à tout le monde :)

dans mon projet de créer un tchat il faut que j'applique sur le client un thread qui exécute une autre fonction qui doit lire les messages.

Hors je doit mettre la fonction en dehors de "main" et la fonction pour lire les messages ne reconnais plus aucune variables ni même les sockets.
Comment puis-je faire ? utiliser les mutex ? de plus je ne sais pas trop comment mettre en place cela surtout que le thread gère une boucle infinie.

voila déjà se que j'ai fait pour le moment. (je vous ais mis seulement les parties qui posent problème car sinon c'est trop long)
Code:

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 48 49 50 51 52 53 54 55 void* message(void* data); int main(int argc, char *argv[]) { /* ..............Variables et socket................ */ pthread_t thread;/* crée un thread */ pthread_create(&thread, NULL, message, NULL);/* Permet d'exécuter le fonction message en parallèle */ while (1) { /* début boucle wirthe */ system("CLS"); printf("\n%s : ", pseudo); fgets(chaine, sizeof chaine, stdin); clean(chaine); snprintf(buffer, sizeof(buffer), "%s : %s \n", pseudo, chaine); send(s, buffer, strlen(buffer), 0); if ( strcmp( chaine, "exit" ) == 0 ) { goto fin; /* je sais goto c'est pas bien mais c'est juste pour faire les testes en attendant :p */ } } /* fin boucle writhe */ pthread_join(thread, NULL); /* .........fermeture socket.............. */ return o; } void* message(void* data); /* Fonction de réception de message */ { while(1) /* boucle de réception des messages */ { memset(buffer, '\0', sizeof(buffer)); n = recv(s, buffer, sizeof(buffer) - 1, 0); printf("%s\n",buffer); } } /* Finc de la fonction de réception des messages */
Merci.

06/05/2010, 10h00
mebibyte
Bonjour,

je suis nouveau dans le domaine...

Mais il y a quelques petits points que je ne saisi pas ...

Quand tu as déclaré ta fonction message, tu as mis en argument "void* data",
à quoi était il sensé correspondre? Dans ta fonction message, tu n'utilises aucune variable data. Mais une chaine de caractère "buffer" et un descripteur de socket "s", (si j'ai bien compris).

Dans ta fonction principale, tu crées ton thread de cette manière:

Code:

pthread_create(&thread, NULL, message, NULL);

Avec comme dernier argument "NULL". Celui ci ne dervait il pas correspondre à l'argument qui dervait être passé à la fonction message?

Mes sugestions:

Code:

pthread_create(&thread, NULL, message, s);

avec "s" pour le descripteur de socket.
et

Code:

void* message(int *s);

avec donc le descripteur de ton socket passé en argument.

Par ailleur la fonction message que tu nous as données n'aurait elle pas un ";" en trop?
Citation:
Code:

1 2 3 4 void* message(void* data); /* Fonction de réception de message */ { while(1) /* boucle de réception des messages */ {
Bon courage.

salut alors depuis je m'oppose à un nouveau problème.

j'ai réussie à sauver une valeur en faisant comme ceci dans les paramètres du thread:
pthread_create(&thread, NULL, message, (void *)&s);

mais pour plusieurs il faut faire une structure que le thread appelle (et la fonction aussi je pense)
donc je voulais savoir comment insérer la structure dans les paramètres du thread.

Code:

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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
struct recep
      {
       SOCKET *s;
       char *buffer;
       char *pseudo;
       int *n;
       };
 
 
 
/*.......................................................................*/
 
 
 
 
pthread_t thread;/* crée un thread */
pthread_create(&thread, NULL, message, (void *)&s);/*Permet d'exécuter le fonction message en parallèle*/
 
while (1)
{ /* début boucle wirthe */
 
printf("\n%s : ", pseudo);
 
    fgets(chaine, sizeof chaine, stdin);
    clean(chaine);
 
 
    snprintf(buffer, sizeof(buffer), "%s : %s \n", pseudo, chaine);
 
   send(s, buffer, strlen(buffer), 0);
 
    if  ( strcmp( chaine, "exit" ) == 0 )
    {
 
       goto fin; /* je sais goto c'est pas bien mais c'est juste pour faire les testes en attendant :p */
 
    } 
} /* fin boucle writhe */ 
 
pthread_join(thread, NULL);
 
 
 
 
 
/*.................................................................*/
 
 
 
 
void* message(void* data) /* Fonction de réception de message */
{
 
while(1)  /* boucle de réception des messages */
   {
memset(buffer, '\0', sizeof(buffer));
*n = recv(*s, buffer, sizeof(buffer) - 1, 0);
  printf("%s\n",*buffer);
   }
 
} /* Finc de la fonction de réception des messages */

Merci d'avoir pris attention :)