Python子线程通过事件与调用者通信

Question

相关：Catch a thread's exception in the caller thread in Python

当我在子线程中捕获异常时：
我需要让线程调用者知道

在相关帖子中，接受的答案检查队列这很好，但它阻止了主调用者做任何其他事情，因为它一直在检查队列

如果它是基于事件的，那将是理想的。

解决方案应该是：主调用者做事（不连续检查子线程中的队列是否有错误），如果子线程内部出现问题，子线程通过一些事件让主调用者知道，主调用者​​处理错误。

我一直在查看不同的文章和解决方案，但所有事件内容都针对与子线程通信的主调用者，反之亦然

子线程通过事件与调用者通信的任何解决方案？

Answer 1

没有“线程调用者”这样的东西。所有线程都是平等的。

在你的脑海中，“主线程”是一种特殊的东西，因为 Python 免费为你提供了它，但就 Python 而言，主线程就像任何其他线程一样。

所以您的问题归结为：如何在两个线程之间交换信息？

有一个或多个队列。

通常，伪代码如下所示：

1. 创建 N 个工作器，连接到输入和输出队列。
2. 将工作放入输入队列
3. 等待输出队列中的结果
4. 加入主题

请注意，您不必在第 3 步中阻止。您还可以询问队列是否有任何元素。如果是这样，那么get() 将不会阻止。如果它是空的，那么你可以做其他事情。

第 4 步通常更容易实现，当您定义一个“kill”命令时，线程会以“I'm done”回复对其进行响应。

然后您可以发送 N 个 kill 命令并等待 N 个回复。之后，您可以确定所有线程都已完成。