python-3.x - Python ThreadPoolExecutor 和 psycopg2 -- 进程在完成前退出

Question

我目前正在构建一个使用 ThreadPoolExecutor 的应用程序，如下所示：

with ThreadPoolExecutor(max_workers = 6) as executor:
   for ns in newssource:
      executor.submit(myFunc, ns)

在 myFunc 中，我做了三件事：

1. 下载 TXT 文件。
2. 分析 TXT 文件并将其保存在本地。
3. 重新打开 TXT 文件并将附加信息保存到 Postgres（通过 psycopg2）。

该过程总是在#3 完成之前结束——我认为连接错误，但我没有看到任何错误消息。该过程刚刚结束......即使我在第三个函数中创建了一个 Postgres 连接和光标，在最后一步。

我似乎找不到这方面的文档。任何建议/帮助将不胜感激。

标签： python-3.xpostgresqlpsycopg2