C-Python asyncio: запуск discord.py в потоке

Мне нужно запустить discord.py в отдельном потоке, так как я не могу заблокировать свой основной поток.
Это игровой сервер C/Python 3.7 (ubuntu 18)

Код C:

int pysDiscord_Init;
...
PyObject *psv_discord;

psv_discord = Python_LoadModule("sv_discord");
if (psv_discord != NULL) {
  pysDiscord_Init = Python_RegisterFunction(psv_discord, "sv_discord", "init");
  Python_Execute(pysDiscord_Init, "");
}

sv_discord.py

import discord
import asyncio
import threading
from concurrent.futures import ThreadPoolExecutor
import multiprocessing

TOKEN = '12345'

client = discord.Client()

def init():
    print("Initializing Discord...")
    print("current_thread: %s" % threading.current_thread())
    t = threading.Thread(target=client.run, args=(TOKEN,))
    t.start()

or

def init():
    print("Initializing Discord...")
    print("current_thread: %s" % threading.current_thread())
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    asyncio.get_child_watcher().attach_loop(loop)
    pool = ThreadPoolExecutor(max_workers=multiprocessing.cpu_count())
    task = loop.run_in_executor(pool, client.run, TOKEN)
    loop.run_until_complete(task)

исключение set_wakeup_fd:

...
Initializing Discord...
current_thread: <_MainThread(MainThread, started 4150019840)>

Exception in thread Thread-1:
 Traceback (most recent call last):
 File "./build/Lib/asyncio/unix_events.py", line 92, in add_signal_handler
 ValueError: set_wakeup_fd only works in main thread

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
 File "./build/Lib/threading.py", line 917, in _bootstrap_inner
 File "./build/Lib/threading.py", line 865, in run
 File "./../source/discord.py-rewrite/discord/client.py", line 550, in run
 File "./build/Lib/asyncio/unix_events.py", line 94, in add_signal_handler
RuntimeError: set_wakeup_fd only works in main thread

Я должен упомянуть, что я попробовал тот же код на питоне (без кода C), и он работает.
Эта ошибка говорит мне о главном потоке. Но я не создаю sv_discord внутри нового потока, и, как вы можете видеть из журнала, это "Main" нить внутри init() метод. Я не понимаю этого.

Источник

1 ответ

Решение

Отвечая на мой собственный вопрос:

Я должен поблагодарить этот источник asyncio-you-a-complex-beast, где я наконец нашел решение.
Окончательный рабочий код выглядит так:

import discord
import asyncio
import threading

TOKEN = '12345'
client = discord.Client()


async def start():
    await client.start(TOKEN) # use client.start instead of client.run


def run_it_forever(loop):
    loop.run_forever()


def init():
    asyncio.get_child_watcher() # I still don't know if I need this method. It works without it.

    loop = asyncio.get_event_loop()
    loop.create_task(start())

    thread = threading.Thread(target=run_it_forever, args=(loop,))
    thread.start()


@client.event
async def on_message(message):
    if message.author == client.user:
        return

    print("on_message content: %s, channel: %s" % (message.content, message.channel))
    await message.channel.send('Hello!')


@client.event
    async def on_ready():
    print("Discord bot logged in as: %s, %s" % (client.user.name, client.user.id))

Моя главная ошибка заключалась в том, что для игры я скомпилировал и использовал последние rewrite версия в то время как внутри системы через пункт я получил 0.16.12 и прочитайте документацию по 0.16.12, пока я должен был посмотреть на discord.py.rewrite (например, внутри on_message Я использовал неправильно client.send_message в то время как я должен был использовать message.channel.send)

Источник

У меня был похожий крайний случай (не совсем то, что предполагалось использоватьasyncioно какого черта) где мне нужно было нитьdiscord.py пример.

В итоге я изменил ваше решение следующим образом:

class discordHost(discord.Client):
    async def on_ready(self):
        print(f'{DThread.discord_client.user} has connected.')

class Threader(Thread):
    def __init__(self):
        Thread.__init__(self)
        self.loop = asyncio.get_event_loop()
        self.start()

    async def starter(self):
        self.discord_client = discordHost()
        await self.discord_client.start(DISCORD_TOKEN)

    def run(self):
        self.name = 'Discord.py'

        self.loop.create_task(self.starter())
        self.loop.run_forever()

if not 'Discord.py' in [t.name for t in tenumerate()]:
    DThread = Threader()

Это делает более или менее то же самое, но я выделил подклассы Thread и подклассы discord.Client чтобы легче было работать с результатом двух.

Только предостережение здесь, является то, чтоasyncio.get_event_loop()должен быть вызван до Thread.start(), иначе он запутается и потеряет контекст основного потока.

Источник
Другие вопросы по тегам