Python并发编程：为什么传入进程池的目标函数不执行，也没有报错？ - 知乎 (zhihu.com)

关键函数是：apply_async()

进程池中，这是大家使用最多的一个函数。

在上面的代码中，为 apply_async() 函数指定了一个可执行的函数对象、函数对象所需参数，以及一个处理结果的回调函数。

pool.apply_async(
            func.work,
            args=(k,),
            callback=func.call_back,
        )

这也是我们使用 apply_async() 最常见写法。这样写存在一个隐患，很容易出现指定函数不执行，也无报错的现象。

对于编程新手，这是非常难排查的bug！

查看 python 官方文档，我们可以看到 apply_async() 的定义如下：

apply_async(func[, args[, kwds[, callback[, error_callback]]]])

重点是最后的 “error_callback”参数。

如果指定了  callback , 它必须是一个接受单个参数的可调用对象。当执行成功时，  callback 会被用于处理执行后的返回结果，否则，调用  error_callback 。
如果指定了  error_callback , 它必须是一个接受单个参数的可调用对象。当目标函数执行失败时， 会将抛出的异常对象作为参数传递给  error_callback 执行。

比较坑的是，error_callback 是一个可选参数。

如果不传入error_callback，那么执行失败时， 抛出的异常就会被pass掉，让人误以为没有报错！

剩余内容具体参考：

Python并发编程：为什么传入进程池的目标函数不执行，也没有报错？ - 知乎 (zhihu.com)