带有不同工人计数的嵌套线池

Question

我已经开始学习Python，并遇到了一个场景，我必须实现两个单独的队列：

• 我有n个流程和两个操作，O1和O2。
• 我想和4名工人一起运行O1。
• O2和1个工人

我当前的代码：

import time
from concurrent.futures import ThreadPoolExecutor

PROCESS_NUM = 4

o1_exe = ThreadPoolExecutor(max_workers=4)
o2_exe = ThreadPoolExecutor(max_workers=1)
    
def O1(x: int):
    print(f'O1: {x} started')
    time.sleep(1)
    print(f'O1: {x} complete')
    
def O2(x: int):
    print(f'O2: {x} started')
    time.sleep(2)
    print(f'O2: {x} complete')
    
def process(x: int):
    O1(x)
    o2_exe.submit(O2, x)

for i in range(0, PROCESS_NUM):
    o1_exe.submit(process, i)

我将获得以下输出：

O1: 0 started
O1: 0 complete
O1: 1 started
O1: 1 complete
O1: 2 started
O1: 2 complete
O1: 3 started
O1: 3 complete

代码的问题是O2根本不运行。

还有其他方法可以使这项工作或使用不同的方法解决方案吗？

我目前正在使用Python 3.9.7