Совместное использование eventlet с системными вызовами

Question

В моем проекте используется eventlet, и теперь я должен асинхронно читать и записывать в файл (на самом деле это устройство). Я попробовал eventlet.tpool.execute() для запуска потока чтения, но он блокирует основной цикл.

Мой вопрос: как запустить поток чтения одновременно с потоком событий? Возможно ли, чтобы эти два потока сообщались в некотором роде?

Быстрый эскиз:

def functionB(): 
    while True: 
    data = readFile() 
    doSomethingWith(data) 

def functionA(): 
    doSomething() 
    tpool.execute(functionB) 
    doSomethingElse() 

Тогда doSomethingElse() никогда не вызывается.

Answer 1

tpool.execute не должен возвращаться до functionB закончился. Ваш не заканчивается, поэтому doSomethingElse() не должен выполняться.

Иными словами, tpool.execute не является огнезадерживающим. Он запускает функцию в потоке ОС и синхронизирует вызывающий. Это очень полезно.

Если вы хотите начать новый вечно работающий поток, просто сделайте это с помощью обычного Python threading.Thread.

Типичный случай использования для tpool.execute:

def main(): 
    f = tpool.execute(open, ...) 
    while True: 
    chunk = tpool.execute(f.read, size) 
    # process chunk 
    tpool.execute(f.close) 

Вы можете попробовать следующий код, чтобы решить вашу проблему:

def functionB(): 
    while True: 
    data = tpool.execute(readFile) # just readFile -> tpool.execute 
    doSomethingWith(data) 

def functionA(): 
    doSomething() 
    eventlet.spawn_n(functionB) # tpool.execute -> spawn_n 
    doSomethingElse()