是否有子进/线程对主线程队列进行操作的方法？以及回调函数范围的问题。。。

# 最终结果列表,全局的味道
GGlobalList = []

def procSome(xx):
    return xxList

def multiProcFun():
    BABTaskDict = {'TkNum': 32,
                   'TkString': 'test String'}

    def procFun(taskInfo):
        aDataList = []
        for i in range(1, 7)
            taskNumber = taskInfo.get('TkNum')
            taskString = taskInfo.get('TkString')
            somethingList = procSome(taskNumber, taskString)
            ...
            ...
            aDataList = aDataList + somethingList
        if aDataList:
            return aDataList
        else:
            return None

    with concurrent.futures.ProcessPoolExecutor(max_workers=3) as executor:
        def cb_fun(res):
            data = res.result()
            if data:
                # global GGlobalList # 很显然这里就算声明了要用，也是不行的
                # GGlobalList = GGlobalList + data   <--报:
                # UnboundLocalError: local variable 'addtomtQueenList' referenced before assignment
                # 错误

        to_do = []
        future = executor.submit(procFun, BABTaskDict).add_done_callback(cb_fun)
        to_do.append(future)

if __name__ == '__main__':
    ltQueen = queue.LifoQueue()
    multiProcFun() 
    for i in GGlobalList:
        ltQueen.put(i)
        
    # 如果能在 procFun 里面直接操作 ltQueen 就好了...

adatalist

def

procfun

ltqueen

4 条回复 • 2020-09-23 11:16:00 +08:00

formaxin

2020-09-23 08:09:09 +08:00 via Android

线程和进程都有队列吧
multiprocessing.queuq

xiaolinjia

2020-09-23 08:57:50 +08:00

子线程无法操作主线程的队列？子进程无法操作主进程的队列？就扯淡。本来队列就是线程和线程通信，进程和进程通信的一种方法。
只是，多线程用的队列是 queue 模块下的。多进程用的队列是 multiprocessing 模块下的 Queue 。
然后你那 queue.LifoQueue 是用于多线程的。

chaoshui

2020-09-23 11:04:41 +08:00

回复不支持 markdown 啊，有点恶心
不是很明白你要做什么，是要在回调中拿到返回值修改全局变量吗

chaoshui

2020-09-23 11:16:00 +08:00

变量命名不规范，改了一下