多处理：在单独的线程上执行新函数的每个n迭代其他线程上的每个迭代

Question

上下文

我有工人设置并在多线程的过程上运行，如下所示：

global_iteration = mp.Value('i', 0)

workers = [Worker(global_iteration) for _ in range(num_threads)]

for w in workers:
    w.daemon=True
    w.start()

[w.join() for w in workers]

每个工人将执行一些操作，然后递增global_iteration。为了清楚起见，工作类的定义如下：

import multiprocessing as mp

class Worker(mp.Process):
    def __init__(global_iteration):
        super(Worker, self).__init__()
        self.global_iteration = global_iteration

    def update_global_iteration():
        with self.global_iteration.get_lock():
            self.global_iteration+=1

    def run():
        ### Do something here ###
        self.update_global_iteration()

我的问题：

我想在每个n n global_iterations上在单独的线程上运行一个函数。我该怎么做？

为简单起见，功能可能是：

def print_global_iterations(global_iterations):
    print('Workers are currently on global iteration {}'.format(global_iterations))