Blockage de thread POSIX.

Version imprimable

18/01/2012, 17h27
Kalite

Blockage de thread POSIX.

Bonjour,

J'ai un serveur multi-client sous linux. Pour chaque client le serveur créer un thread POSIX.

Afin de savoir si le client est toujours connecter, toute les 5s je voudrait envoyer un "ping" (ce n'est pas un vraie ping).
Si je ne reçoit pas la réponse dans les 0.5s, j'arrête proprement le traitement.

Mon problème est le suivant: Comment mettre en "pause" un thread au bout d'un temps déterminer ? Ceci afin d'envoyer le "ping" ou d'indiquer que la réponse n'a pas été reçue a temps.
Il ne faut pas que cela interrompe les autres threads.

PS : les temps sont arbitraires.
18/01/2012, 18h53
Lightness1024

premier truc, il est impossible de bloquer des threads à partir d'autre threads, et notamment il n'est pas possible de les faire quitter.

un thread se met en pause tout seul et s'arrete tout seul, tout l'ordonnancement au sein d'un process multi thread doit se faire coopérativement.

par exemple, tu peux lire la doc des "interuptions point" de boost qui explique que en passant sur un interrupt point si un autre thread a demandé l'arret de ce thread une exception sera lancée. c'est la qu'on voit que c'est coopératif, un thread doit poller tout seul comme un grand régulirement si qqun lui a demandé de s'arreter.

ca c'est pour l'arret, mais c'est la meme chose pour tout autre communication, par exemple tes threads qui discutent avec les clients pourraient etre en attente passive sur un flux avec un timeout. si ce timeout est écoulé l'OS reveille le thread et tu peux avoir un code qui dit que tu es sorti du wait a cause d'une timeout et alors tu peux ecrire dans un manager général (avec un lock) que ton client ne répond plus et tu sucides le thread avec un return en cascade ou une exception.

tu peux aussi signaler le main thread avec une condition variable que quelque chose a changé dans le manager de clients, le main thread qui dormait parce qu'il s'occupe de l'UI va faire un tour de "update from model" pour afficher le changement.

je ne sais pas si ca t'aide mais ta question n'était pas super claire donc moi je met comment je ferais.
18/01/2012, 22h19
Kalite

Merci pour les informations.

Le traitement que j'effectue dans le thread est très court mais j'ai des contraintes de performance très élevé. Donc je cherchais à éviter de tester régulièrement le temps écoulé depuis le dernier "ping" en utilisant la fonction timeofday().

Citation:

Envoyé par Lightness1024

premier truc, il est impossible de bloquer des threads à partir d'autre threads, et notamment il n'est pas possible de les faire quitter.

Voir : pthread_cancel, pthread_setcancelstate , pthread_setcanceltype , pthread_testcancel

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
62
 
The following functions are required to be cancellation points by POSIX.1-2001
       and/or POSIX.1-2008:
 
           accept()
           aio_suspend()
           clock_nanosleep()
           close()
           connect()
           creat()
           fcntl() F_SETLKW
           fdatasync()
           fsync()
           getmsg()
           getpmsg()
           lockf() F_LOCK
           mq_receive()
           mq_send()
           mq_timedreceive()
           mq_timedsend()
           msgrcv()
           msgsnd()
           msync()
           nanosleep()
           open()
           openat() [Added in POSIX.1-2008]
           pause()
           poll()
           pread()
           pselect()
           pthread_cond_timedwait()
           pthread_cond_wait()
           pthread_join()
           pthread_testcancel()
           putmsg()
           putpmsg()
           pwrite()
           read()
           readv()
           recv()
           recvfrom()
           recvmsg()
           select()
           sem_timedwait()
           sem_wait()
           send()
           sendmsg()
           sendto()
           sigpause() [POSIX.1-2001 only (moves to "may" list in POSIX.1-2008)]
           sigsuspend()
           sigtimedwait()
           sigwait()
           sigwaitinfo()
           sleep()
           system()
           tcdrain()
           usleep() [POSIX.1-2001 only (function removed in POSIX.1-2008)]
           wait()
           waitid()
           waitpid()
           write()
           writev()

Citation:

Envoyé par JeitEmgie

Voir : pthread_cancel, pthread_setcancelstate , pthread_setcanceltype , pthread_testcancel

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
62
 
The following functions are required to be cancellation points by POSIX.1-2001
       and/or POSIX.1-2008:
 
           accept()
           aio_suspend()
           clock_nanosleep()
           close()
           connect()
           creat()
           fcntl() F_SETLKW
           fdatasync()
           fsync()
           getmsg()
           getpmsg()
           lockf() F_LOCK
           mq_receive()
           mq_send()
           mq_timedreceive()
           mq_timedsend()
           msgrcv()
           msgsnd()
           msync()
           nanosleep()
           open()
           openat() [Added in POSIX.1-2008]
           pause()
           poll()
           pread()
           pselect()
           pthread_cond_timedwait()
           pthread_cond_wait()
           pthread_join()
           pthread_testcancel()
           putmsg()
           putpmsg()
           pwrite()
           read()
           readv()
           recv()
           recvfrom()
           recvmsg()
           select()
           sem_timedwait()
           sem_wait()
           send()
           sendmsg()
           sendto()
           sigpause() [POSIX.1-2001 only (moves to "may" list in POSIX.1-2008)]
           sigsuspend()
           sigtimedwait()
           sigwait()
           sigwaitinfo()
           sleep()
           system()
           tcdrain()
           usleep() [POSIX.1-2001 only (function removed in POSIX.1-2008)]
           wait()
           waitid()
           waitpid()
           write()
           writev()

oui je crois que ca confirme ce que je dis. le thread annulé doit passer sur un point de coopération avant de pouvoir subir une volonté extérieure.