Discussion :

[kiby56]

Bonjour,

J'ai actuellement un process exe (py2exe) que je place en priorité haute comme çà :

Code :

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

1
2
3
4
 
p = psutil.Process(os.getpid())
p.set_nice(psutil.HIGH_PRIORITY_CLASS)
p.set_cpu_affinity([0])

Ensuite, je lance 2 threads (modules threading):

Code :

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

1
2
3
4
5
th_Listen = threading.Thread(target = checkMsgThread)
    th_Listen.start()
 
    th_Report = threading.Thread(target = reportThread)
    th_Report.start()

Le th_Report fonctionne bien tout le temps même quand la bécane est à 100% d'utilisation processeur à cause d'autres programmes, par contre le th_Listen ne fonctionne plus (check de message tcp avec zmq, il ne reçoit plus rien quand le cpu est à 100%)

Je ne maitrise pas bien tout çà, mais comment faire pour que les deux threads continuent de tourner normalement même quand une autre appli prend tout le temps cpu restant ? (mes threads sont minime en cpu, avec que çà le cpu reste à 0% alors que tout fonctionne bien).

Merci,
Kib

[PauseKawa]

Bonjour,

th_Report et th_Listen sembles s'occuper de la partie communication :
th_Report aussi utilise zmq ? Quelle est sa fonction ? send ?
Je ne connais pas zmq mais il me semble qu'il utilise pour le send des buffers pour les messages gérés par des threads de communication internes au Context, ceci afin de ne pas être 'bloquant'. Je ne sais pas s'il en est de même pour recv (A vérifier dans la doc.) : Si ce n'est pas le cas cela pourrais, peut-être, expliquer la chose.
A prendre avec de pincettes car pures élucubrations dominicales.

Je sais que c'est moins 'efficace' mais avez vous tester juste avec socket ?

Un petit test de multiprocessing avec élévation de la priorité du process ?
L'exemple de la doc multiprocessing pour l' id du process :

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
from multiprocessing import Process
import os
 
def info(title):
    print title
    print 'module name:', __name__
    if hasattr(os, 'getppid'):  # only available on Unix
        print 'parent process:', os.getppid()
    print 'process id:', os.getpid()
 
def f(name):
    info('function f')
    print 'hello', name
 
if __name__ == '__main__':
    info('main line')
    p = Process(target=f, args=('bob',))
    p.start()
    p.join()

Après vous connaissez les win32process.HIGH_PRIORITY_CLASS et autres.

@+