请教如何在 concurrent.futures 子进程里，无冲突地使用整个程序的全局队列？

from concurrent import futures from multiprocessing import Manager # 此函数无限循环,消费掉 sqltextqueen def procSQL(sqltextqueen): while True while not sqltextqueen: inserttext = sqltextqueen.get() mysqldb =xxxx mysqldb.insert(inserttext) #略 time.sleep(3) if __name__ == '__main__': MainSQLProcess = futures.ProcessPoolExecutor(max_workers=1) # 全局 SQL 队列 manager = Manager() SQLQueen = manager.queue MainSQLProcessRet = MainSQLProcess.sumit(procSQL,SQLQueen) 

################ another.py ##################

 TaskProcess = {} TaskProcesRet = {} # 提交任务 TaskinfoA = { 'TYPE': 'CPS' 'countt': countt, 'Rget': stRget, 'DLoption': DLoption, 'DTO': mtinfo.get('DTO'), 'errFlag': errFlag # 字典内容引用的一些值，有些是从函数外几层的函数传过来的,距离 main()已经好 N 层了 } TaskProcess['A'] = futures.ProcessPoolExecutor(max_workers=1) TaskProcess['B'] = futures.ProcessPoolExecutor(max_workers=1) # 交给进程池 TaskRet['A'] = TaskProcess['A'].submit(ProcessSuit,TaskinfoA) TaskRet['B'] = TaskProcess['B'].submit(ProcessSuit,TaskinfoB) 

ProcessSuit 函数里,产生的一些 SQL 语句,希望能及时送到全局队列里去消费,而不是通过 concurrent.futures 的回调 函数一层一层地往回 main 送到才处理...

我尝试了把 SQLQueen 引用在

 TaskinfoA = { 'TYPE': 'CPS' 'countt': countt, 'Rget': stRget, 'DLoption': DLoption, 'DTO': mtinfo.get('DTO'), 'errFlag': errFlag, 'SQLQueen' : SQLQueen # <----- } 

是不行的，貌似是有个 concurrent.futures pick 锁什么的 请教如何可以让各个子进程，都能不冲突地，实时送到全局的队列里，各自进程都可以 put，get，但是又不冲突？