1

Existe alguma forma de parar uma thread em python? E é uma má praticas fazer isso?

1
  • pergunta e resposta copiadas e coladas do SO Inglês seria no minimo justo dar credito a quem perguntou/respondeu.... Commented 9/10/2018 às 15:58

1 Resposta 1

1

É uma má pratica parar de forma abruptamente uma thread em qualquer linguagem.

Vamos pensar A thread está com algum recurso critico que precisa ser fechado de forma correta. A thread tem outras threads que devem ser paradas junto com essa thread.

A melhor maneira de lidar com isso se você puder, (se você está administrando suas próprias threads) é ter uma flag exit_request que cada thread checa regularmente para ver se é hora de fechar.

Vamos para um exemplo:

import threading

class StoppableThread(threading.Thread):
    """Thread class com metodo de stop(). A thread precisa checar 
    regularmente pela condição de stopped() ."""

    def __init__(self):
        super(StoppableThread, self).__init__()
        self._stop = threading.Event()

    def stop(self):
        self._stop.set()

    def stopped(self):
        return self._stop.isSet()

Há casos, no entanto, quando você realmente precisa matar uma thread. Um exemplo é quando você está fazendo o wrap de uma biblioteca externa que está ocupada e você deseja interrompê-la.

O exemplo a seguir permite que (com algumas restrições) lance uma exceção em uma thread do Python:

def _async_raise(tid, exctype):
    '''Lanca uma excecao na threads com id tid'''
    if not inspect.isclass(exctype):
        raise TypeError("Somente tipos podem ser lancados (nao instancias)")
    res = ctypes.pythonapi.PyThreadState_SetAsyncExc(tid,
                                                  ctypes.py_object(exctype))
    if res == 0:
        raise ValueError("thread com invalido id")
    elif res != 1:
        # "Se lancar um numero maior que um, eh um problema,
        # e voce deveria chamar novamente com exc=NULL para reverter o efeito"
        ctypes.pythonapi.PyThreadState_SetAsyncExc(tid, 0)
        raise SystemError("PyThreadState_SetAsyncExc falhou")

class ThreadWithExc(threading.Thread):
    def _get_my_tid(self):
        if not self.isAlive():
            raise threading.ThreadError("the thread is not active")

        if hasattr(self, "_thread_id"):
            return self._thread_id

        for tid, tobj in threading._active.items():
            if tobj is self:
                self._thread_id = tid
                return tid

        # TODO: em python 2.6, existe uma forma mais simples : self.ident

        raise AssertionError("nao pode determinar as threads com id")

    def raiseExc(self, exctype):
        _async_raise( self._get_my_tid(), exctype )

Conforme observado, isto não é perfeito, porque se a thread estiver ocupada fora do interpretador Python, não vai pegar a interrupção.

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .