0

Estou estudando o módulo asyncio do Python e existe a função run_coroutine_threadsafe que deve ser executado numa thread diferente daquela que está o loop de eventos. Segue meu script:

#!usr/bin/python3
# -*- coding: utf-8 -*-

import asyncio
import threading


def target():
    print('Iniciou a thread')
    #asyncio.set_event_loop(None)
    #loop = asyncio.new_event_loop()
    asyncio.run_coroutine_threadsafe(blah(), loop)
    print('Finalizou a thread')


async def blah():
    print('Thread atual:', threading.current_thread().name)


async def main():
    thread = threading.Thread(target=target, args=(), kwargs={}, name='Minha Thread')
    thread.setDaemon(True)
    thread.start()
    thread.join()
    print('finalizou')


if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    try:
        loop.run_until_complete(main())
    finally:
        loop.close()

# Output
Iniciou a thread
Finalizou a thread
finalizando

O problema é que a corotina blah nunca é invocada pelo função run_coroutine_threadsafe mas não consigo encontrar o motivo, tentei até mesmo instanciar um novo loop de eventos (como podem ver nas linhas comentadas) mas nem mesmo assim o script funciona. O que estou errando?

6
  • Não houve saída no terminou. 15/08/2018 às 0:58
  • Troquei os print pelo sys.stdout.write mas nem mesmo assim funcionou. 15/08/2018 às 1:03
  • Devo ter me enganado sobre isso. Desculpe-me.
    – Woss
    15/08/2018 às 1:15
  • Que isso eu agradeço por estar tentando me ajudar. 15/08/2018 às 1:16
  • Pelo o que entendi, lendo por cima a documentação, você não precisa criar uma thread para isso, a própria função run_coroutine_threadsafe irá executar em outra thread.
    – Woss
    15/08/2018 às 1:22

1 Resposta 1

1

O problema é que você está chamando loop.close() antes de ele ter a oportunidade de rodar a rotina blah.

A rotina blah está agendada para execução no loop, porém a thread principal (que tem o loop) está presa em main()... Ela nunca cedeu controle ao loop para que ele rode outras rotinas, e quando main() termina o loop é fechado.

Por exemplo, colocando 1 segundo de espera antes de terminar o loop:

...
thread.join()
await asyncio.sleep(1)
print('finalizou')
...

Coloque esse await sleep em main() entre o join() e o print como no exemplo e vai ter o resultado que você espera. Pois o await devolve o controle para o loop.

Um outro exemplo é usar um evento para sinalizar o fim do programa:

import asyncio
import threading

def target(e):
    print('Iniciou a thread')
    asyncio.run_coroutine_threadsafe(blah(e), loop)
    print('Finalizou a thread')

async def blah(e):
    print('Thread atual:', threading.current_thread().name)
    e.set() # sinaliza o final da rotina, autorizando o loop a terminar


async def main():
    e = asyncio.Event()
    thread = threading.Thread(target=target, args=(e,), kwargs={}, name='Minha Thread')
    thread.setDaemon(True)
    thread.start()
    await e.wait() # devolve o controle ao loop e espera que
                   # a rotina sinalize o fim do programa
    print('finalizou')

Dessa forma antes de terminar o loop, esperamos pela execução da rotina blah usando um evento asyncio.Event().

11
  • A espera da finalização da thread com o método join() ocorre somente se o controle for retornado ao event loop? 15/08/2018 às 19:09
  • Quer dizer que mesmo que eu agende uma corotina numa thread diferente se o event loop for o mesmo preciso ceder o controle ao loop de eventos para que a mesma seja executada? 15/08/2018 às 19:13
  • @ThiagoLuizS Primeira pergunta: não, você pode retirar o join() que vai funcionar do mesmo jeito. O que você não pode fazer é terminar o loop... O seu loop tem que ficar ativo, sempre esperando alguma coisa - no exemplo foi o sleep mas num programa real o loop provavelmente fica a maior parte do tempo esperando por io.
    – nosklo
    15/08/2018 às 19:33
  • @ThiagoLuizS segunda pergunta: Você usa run_coroutine_threadsafe para agendar uma corotina que será executada na thread principal, quando o loop tiver tempo pra isso. O erro do seu código foi somente ter finalizado o loop - geralmente o loop fica esperando algo acontecer, até terminar tudo que o programa tem que fazer. Quando não tiver mais o que esperar, aí sim você chama loop.close().
    – nosklo
    15/08/2018 às 19:35
  • Se run_coroutine_threadsafe é executada na MainThread qual o motivo do mesmo ser threadsafe? 15/08/2018 às 19:39

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 .