Ничего вы не понимаете....

Тут не оператор ЭВМ, тут расчёт ЭВМ: один несёт ноут, второй — генератор.

Да, да, я уже видел. Да хочу :-)

Мальчики и девочки, желательно извращенцы, а подскажите будь ласка.

Есть у меня очень странно написанный легаси на твистеде, там делается callInThread, в внутри опять используются deferred. Но твистед это не смущает, и в принципе оно работает.

И вот заставила нужда перейти на asyncioreactor, потому что для twisted'a подходящей библиотеки не нашел, а самому писать сложно, да и некогда, и столкнулся с тем, что фьючеры asyncio в тредах не работают, потому что там банально нет эвент-лупа, он только в главном потоке.

Налепил костыль - передаю луп из главного потока в остальные и там вызываю:

def set_loop_if_not_set(loop):
    try:
        asyncio.get_event_loop()
    except RuntimeError:
        asyncio.set_event_loop(loop)

Оно сразу ожило, но что-то гложут меня сомнения - а не распидорасит ли всё к какой-нибудь матери? Создавать отдельный луп в каждом треде я не могу, он должен быть тот самый, который к реактору твистеда привязан. Или это случай когда не попробуешь не узнаешь?

def set_loop_if_not_set(loop):
    try:
        asyncio.get_event_loop()
    except RuntimeError:
        asyncio.set_event_loop(loop)

Я возможно что-то путаю, но вроде как из соседнего треда можно было шедулить таску в главный луп ещё с питона 3.4

Вот по поводу ляжет или нет текущая реализация, предположу что это вопрос времени. asyncio loop вообще thread safe ?

Возможно поскольку ты вызывает его через reactor то, там есть у самого twisted какие-то заглушки от этого. Но не факт.

Насколько я знаю евент луп не потоко-безопасен.
Зашедулить в из треда можно - сейчас найду пример.

Вроде как вот это

loop.call_soon_threadsafe(loop.create_task, my_coroutine())

Где loop - это евент луп переданный как-то в тред

@proofit404 спасибо за подсказку ))

loop.call_soon_threadsafe(loop.create_task, my_coroutine())

это совсем низкоуровневая какая-то штука с коллбеками )

А, ну вот эта обёртка вызвает внутри себя то что я привел. Она только делает доп. проверки и заворачивает корутину в калбяк, который будет вызван в потоке, где живёт евент-луп

(this one)

Замечательная новость. Надо подкинуть идею использования этого в сигнатурах функций вместо бесполезного singledispatch

афигенно.. то есть даже не сишный switch, а нормальный pattern matching как в нормальный функциональных языках.

Нет. В нормальных языках сопоставление с образцом умеет на этапе компиляции сказать, что у тебя не все кейсы покрыты и доказать это на уровне типов.