如何确保 Python 线程在其目标函数完成后终止？

Question

我有一个生成线程的服务。
线程通过提供目标函数来启动。
当函数结束时，线程似乎不会“死亡”。我知道这一点是因为该线程与 Paramiko 建立了一些 SSH 连接（通过 Fabric)，如果我执行 lsof，我会看到 SSH 连接在函数完成后仍然处于活动状态。
如何确保线程在其目标函数完成时终止？

这是我正在使用的示例：

from time import sleep
from threading import Thread
from fabric.api import run, settings

def thread_func(host):
    with settings(host_string=host):
        run('ls -lht /tmp')

def spawn_thread(host):
    t = Thread(
        target=thread_func,
        args=(host,)
    )
    t.start()

spawn_thread('node1.example.com')
while True:
    sleep(1)

如果我运行 sudo lsof |当上面的代码处于无限循环中时，在另一个终端中运行 grep ssh 我会看到以下内容，即使在我知道线程不应再存在之后：

python    6924      daharon    3u     IPv4             170520        0t0        TCP 10.1.1.173:47368->node1.example.com:ssh (ESTABLISHED)
python    6924      daharon    5u     IPv4             170524        0t0        TCP 10.1.1.173:47369->node1.example.com:ssh (ESTABLISHED)
python    6924 6930 daharon    3u     IPv4             170520        0t0        TCP 10.1.1.173:47368->node1.example.com:ssh (ESTABLISHED)
python    6924 6930 daharon    5u     IPv4             170524        0t0        TCP 10.1.1.173:47369->node1.example.com:ssh (ESTABLISHED)
python    6924 6932 daharon    3u     IPv4             170520        0t0        TCP 10.1.1.173:47368->node1.example.com:ssh (ESTABLISHED)
python    6924 6932 daharon    5u     IPv4             170524        0t0        TCP 10.1.1.173:47369->node1.example.com:ssh (ESTABLISHED)

Answer 1

您确定您的结构模块仅在 ls 命令期间执行 ssh 操作吗？ 等效的操作。

也就是说，它应该执行与ssh 主机 ls -lht /tmp

此命令行将打开远程 shell 来运行 ls -lht 命令，然后关闭。

但我怀疑 Fabric 库可能会执行相当于：

ssh host

host$ ls -lht /tmp
。
。

当然，它不提供真正的 tty，但有不同的 ssh 选项允许在没有交互式 tty 的情况下保持连接打开。这在某些情况下是可取的（例如，如果您在同一主机上运行大量命令，此技术将重用现有的 ssh 会话，而不是每次都打开新会话。检查文档以获取启用或禁用此类会话缓存的参数。