multithreading et timer

Version imprimable

bonjour,
je suis entrain de faire une application qui doit (mais peut ne pas) finir une tache dans un temps imparti.
j'ai donc decider d'utiliser 2 threads car dans certain cas la dite tache peut etre entrain de lire une socket ou un discripteur qui n'est pas pret (donc attend).

voici le main:

Code:

1
2
3
4
pthread_t tid,ctr,*ctr_ret;
pthread_create(&ctr,(void *)m_timer,NULL);
pthread_create(&ctr,(void *)operate,NULL);
pthread_join(ctr,(void **)&ctr_ret);

je passe simplifie le code de operate qui est trop long pour etre mis ici (sauf si vous insistez):

Code:

1
2
3
4
5
6
7
8
9
10
11
size=read_myfd(fd,4);
if(size<0)
{
   free(myvar);
   close(fd);
   return NULL;
}
total_size+=size;
REALLOC(char,myvar,total_size);
...
return myvar;

puis la fonction m_timer

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
void m_timer(int interval)                                                                           
{   
    time_t entrance,now;                                                                             
 
    time(&entrance);                                                                                 
    do                                                                                               
    {   
        time(&now);
        if(now-entrance>=interval)                                                                   
        {   
            fprintf(stderr,"timeout exiting\n");                                                     
            break;                                                                                   
        }
    }while(1);                                                                                       
 
}

ma question est comment faire en sorte que lorsque m_timer termine, je puisse terminer aussi operate en ayant la possibilite de free(myvar)?
merci pour le temps que vous passez a lire mes idee tordus, peut etre qu'il y a mieux a faire que du multithreading sur le coup?

20/11/2013, 09h58
Médinoc

Ouch! Une boucle d'attente active?
Et en plus, avec des casts de pointeur de fonction?

En plus, on n'a pas toute la spécification du problème. Qu'est-ce qui doit se passer si le timeout expire et que la lecture est toujours en cours? Qu'est-ce qui doit se passer si la lecture se termine dans le temps imparti? etc.
20/11/2013, 10h20
mith06

Citation:

ma question est comment faire en sorte que lorsque m_timer termine, je puisse terminer aussi operate en ayant la possibilite de free(myvar)?

Tu peut utiliser les 3 ème paramètre de la fonction pthread_create (ici à NULL), pour passer un pointer sur une zone mémoire (structure), qui contiendra ton intervalle de temps, et un drapeau qui indiquera de quitter le thread (utilise pthread_exit). Il faudra dans la boucle des thread venir régulièrement lire ou écrire dans ce drapeau.
N'oublie pas de protéger tes accès à cette structure par un pthread_mutex_t (que tu peux d’ailleurs intégrer à la structure).

Citation:

j'ai donc decider d'utiliser 2 threads car dans certain cas la dite tache peut etre entrain de lire une socket ou un discripteur qui n'est pas pret (donc attend).

Tu ne peux pas arrêter un thread qui effectue une lecture bloquante sur un descripteur. Tu dois soit paramétrer le descripteur pour que la lecture soit non bloquante. Soit être sure qui il a des données à lire sur le descripteur (fonction "select")

j'espère aider.
@+
20/11/2013, 10h23
lilington

laisses tomber les cast, j'ai pas recopier textuellement ce qui devait etre.
si ca se termine dans les temps imparti, on traite myvar.
je me rend compte en relisant que c'est pas tres propre surtout qu'on doit recuperer la valeur de myvar qui est char *.
bref le probleme n'est pas vraiment la, celui je le reglerai.

@mith06, oui pour le 3eme parametre, en faite il n'etait pas supposer etre a NULL mais bien une structure, je vais donc si j'ai bien compris ajouter l'intervall un un drapeau genre TO_exit (0=continue,1=timeout). Toujours si j'ai bien compris dans le thread m_timer quand le temps est arrive je met to_exit=1 (apres mutex biensur) et dans operate je guette de temps en temps la valuer to TO_exit.
si c'est bien ce que tu me proposes, j'ai un autre probleme. la fonction readfd utilise read qui bloque tant qu'il n'a pas lu de caractere ou pas eu d'erreur, la ca va me posser un probleme pour tester la valeur du flag
20/11/2013, 10h33
mith06

j'avais éditer mon poste entre temps...;)

Citation:

j'ai donc decider d'utiliser 2 threads car dans certain cas la dite tache peut etre entrain de lire une socket ou un discripteur qui n'est pas pret (donc attend).

Tu ne peux pas arrêter un thread qui effectue une lecture bloquante sur un descripteur. Tu dois soit paramétrer le descripteur pour que la lecture soit non bloquante. Soit être sure qui il a des données à lire sur le descripteur (fonction "select")
20/11/2013, 10h54
lilington

donc je resume, tu confirmes et je marque resolut :D.

je passe le flag aux deux fonctions, l'intervall a m_timer
dans m_timer je mets le flag a 1 quand le temps est ecoule,
dans operate je verifie a chaque iteration si le flag est passer de 0 a 1 et avant de commencer a faire un action sur le descripter je verifie avant avec select.
si le drapeau est a 1 je peut liberer toute la memoire utiliser et fermer les descripteurs.
on va faire encore jolie, si operate fini avant m_timer c'est lui qui demande a m_timer d'arreter.
j'ai bon? si tu vois un probleme ...

en y pensant je me dis que si select peut m'empecher d'attendre inutilement read, je peux donc me passer du 2eme thread. et just tester si fd est prets sinon juste tester le l'interval?
20/11/2013, 11h19
mith06

Oui tu peux te passer du deuxième thread :ccool:

Et d'une manière générale :

finir une tache dans un temps imparti => Oublier tout ce qui est asynchrone => oublier tout ce qui est lecture/attente bloquante (Attention à pthread_mutex_lock qui est bloquant, mais heureusement il y a pthread_mutex_try_lock).
21/11/2013, 02h45
lilington

Merci beaucoup hein!
je vais jetter un coup d'oeil sur select que j'ai jamais utiliser et ca devrait aller donc

bon pour des fois ou ca interresserai quelqu'un d'autre je mets le code
la function operate:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
 
int wns=checkfd_timeout(f,10); //10s pour tester le descripteur avant chaque read
fprintf(stderr,"timeout returned %d\n",wns);                                               
        if(wns<=0)//select_error or timeout reached
        {
                close(f);
                clean_memory(); 
                return NULL;
        }
        size=read_myfd(fd,4);  
       ...
       return myvar;

la fonction pour tester le descripteur en ecriture.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
int checkfd_timeout(int f,int tval)
{
    fd_set fds;
    struct timeval timeout;
    int rc;
 
    timeout.tv_sec=tval;
    timeout.tv_usec=0;
 
    FD_ZERO(&fds);
    FD_SET(f,&fds);
 
    rc=select(sizeof(fds)*8,&fds,NULL,NULL,&timeout);
    return rc;                                                                                     
}

en esperant que la solution a mon probleme serve a un autre.
merci pour l'aide.