Problème avec Twisted et threads

Question

Certains d'entre vous qui sont plus expérimentés avec Twisted me jugeront probablement à propos de l'utiliser avec des threads - mais je l'ai fait :). Et maintenant, je suis en quelque sorte en difficulté - j'ai un serveur d'application qui écoute les requêtes des clients et chaque fois qu'un nouveau client se connecte il engendre un autre thread que j'oublie probablement de fermer correctement, car après un certain temps, le serveur s'arrête demandes de traitement. Eh bien, j'ai 3 différents types de threads et pour l'un de ceux-ci il arrive - la chose est que je ne suis pas sûr de la bonne façon de le faire, Thread.join() semble ne pas fonctionner et faire cat /proc/<pid>/status il me donne toujours Threads: 43 lorsque le serveur cessé de travailler. Donc, je cherche un moyen de déboguer cela et voir comment puis-je fermer correctement les discussions.

Et oui, je sais à propos de cette question:

Is there any way to kill a Thread in Python?

et probablement beaucoup d'autres.

Answer 1

La "méthode torsadée" pour faire quoi que ce soit à l'extérieur de la boucle du réacteur (aka threads de spawn) est twisted.internet.threads.deferToThread.

Par exemple:

from twisted.internet import threads 

def sthToDoInSeparateThread(): 
    return 3 

d = threads.deferToThread(sthToDoInSeparateThread) 

deferToThread exécutera sthToDoInSeparateThread en thread séparé et riposté defered d dès fil est arrêté.

Answer 2

Vous voulez probablement juste faire mythread.setDaemon(True) afin que vos discussions se terminent lorsque le processus principal se termine.