我有一个脚本，它使用 pathos ProcessPooldata()在多个数据点上并行执行一个函数。
调用的函数data()计算并将结果发送到调用的单个对象Database，由于大量推送被发送到数据库，我添加了一个简单的队列，当队列大小大于 500 时，它被推送到数据库。
当所有数据点都已映射但类队列中仍有一定量的数据Database（在每个进程中，进程 1 可能有 100 个进程 2 可能有 200 个）时，就会出现问题。
我写了一个函数来在退出时刷新，但是如何在所有进程上调用该函数？