python多处理池阻塞主线程

Question

我有下面的代码片段，它试图在多个子进程之间分割处理。

def search(self):
    print("Checking queue for jobs to process")
    if self._job_queue.has_jobs_to_process():

        print("Queue threshold met, processing jobs.")
        job_sub_lists = partition_jobs(self._job_queue.get_jobs_to_process(), self._process_pool_size)
        populated_sub_lists =  [sub_list for sub_list in job_sub_lists if len(sub_list) > 0]
        self._process_pool.map(process, populated_sub_lists)
        print("Job processing pool mapped")

while循环中的主进程正在调用search函数，如果队列达到阈值计数，则处理池将映射到进程函数，其中作业来自队列。我的问题是，python多处理池是在执行期间阻塞主进程，还是立即继续执行？我不想遇到这样的情况，“has_jobs_to_process（）”的计算结果为true，并且在处理作业的过程中，另一组作业的计算结果为true，并且再次调用“self._process_pool.map（process，populated_sub_list）”，因为我不知道在进程运行时再次调用map的后果。

Answer 1

在多处理文档中，多处理。map将在执行过程中阻止主进程，直到结果准备就绪，将进行多处理。map_async将不会。

Answer 2

多重处理。Pool.map阻塞调用线程（不一定是Main Thread！），而不是整个进程。父进程的其他线程不会被阻塞。您可以从父进程中的多个线程调用pool.map，而不破坏任何东西（尽管没有太大意义）。这是因为池使用线程安全队列。内部队列为它的_taskqueue。