使用ib_insync进行多线程和异步执行

如何解决使用ib_insync进行多线程和异步执行

使用ib_insync实现多线程时，我面临一个困惑的问题。我对多线程和异步编程的了解肯定不足以解决此问题。 有趣的是，只有使用ib.sleep命令才可以设置障碍，而其他功能似乎也可以正常工作。

以下是两种情况-一种不带多线程，一种带。没有多线程，一切都可以正常工作，但是当使用多线程并行运行时，我得到以下警告，并且代码停止。

ERROR:  missing FROM-clause entry for table "message"
LINE 1: ...dent.name FROM MESSAGES INNER JOIN RESPONDENTS ON Message.re...

我想念什么？我知道ib.sleep是一个协程，需要在异步函数中等待，但是我不明白直接调用它是如何工作的，但是只能在线程中失败。 正确实现此目标的最佳方法是什么？

RuntimeWarning: coroutine 'sleep' was never awaited

编辑：我要解决的用例是用不同的参数并行调用一个函数。相应地编辑了上面的示例代码。这里的问题是ib_insync是基于asyncio的异步实现，因此运行多个线程失败。

解决方法

在任何一种情况下，该功能均无法正常工作，只是在主线程中未显示警告。未尽一切努力的RuntimeWarning是在尽力而为的基础上提供的，不能保证在所有情况下都将其释放。

要解决此问题，首先应避免混合使用线程和异步。例如，如果需要并行运行多个协程，则可以使用asyncio.crate_task将它们作为任务生成，然后等待其中的一些或全部。或者，您可以使用asyncio.gather实用工具为您执行此操作：

result1,result2,... = await asyncio.gather(coro1(),coro2(),...)