Discussion :

[sefesfe]

Bonjour j'aimerait réaliser un programme qui lance un commande qui établie un time.sleep(5) puis ensuite qui récupère une première fois le résultat qui a été développer par la commande sans que celle ci soit arrêter par la suite la récupération du flux stdin doit s'établir tout les time.sleep(1) !

Le programme que je développe doit prendre en compte de l'évolution du second programme , ce doit être quelque chose en Temp réel !

Merci de votre compréhension !
Cordialement ,
Sefesfe

[VinsS]

Salut,

Tout d'abord, time.sleep(x) est bloquant. Donc, sous réserve de détails de ton code, je pense que ce n'est pas ce qu'il te faut.

Qu'est-ce que ton code qui doit tourner en second plan ? tu parles de stdin, c'est un subprocess ?

Avec subprocess il y a des solutions pour gérer les temps de réponse-execution.

Mais faudra nous en dire un peu plus.

[shaiHulud]

Bonjour,

Il y a grosso modo trois approches possibles:
- Des threads (nécessite de locker en cas d'accès concurrents) : le thread principal essaye d'obtenir des données toutes les secondes, tandis que le thread auxiliaire met à jour les donnée
- Des processus (nécessite de les faire communiquer). A priori peu adapté à ton problème car il faudra faire transiter les données entre les processus
- De l'asynchrone, ou l'on découpe les taches en unité d'éxécution élémentaire auxquelles on donne successivement la main (cf la bibliothèque Twisted par exemple).

Dans ton cas, le threading me semble le plus simple. Voici un exemple dont tu pourra t'inspirer. Ici, je traite le cas ou on attends que la Tache_Lourde aie fini. Tu aura besoin d'un peu plus pour faire communiquer les thread dans ton cas (surement une queue qui te permettra de stocker les résultats successifs de Tache_Lourde dans un contexte threadé)

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
 
def Tache_Lourde(shared_memory):
    """ Utilise une liste pour prévenir le thread surveillant que c'est fini """
    result= traitement() # la tache que tu veux faire
    shared_memory[0]= result
 
def Surveiller():
    shared_memory= []
    threading.Thread(target= lambda: Tache_Lourde(shared_memory)).start()
    time.sleep(5)
    while not(shared_memory):
        time.sleep(1)