Python 多处理共享变量

Question

我正在尝试与我在其中启动的其他进程共享类实例/对象变量，因为我需要同时运行多个函数，以从键盘和鼠标记录宏并在以后重新播放它们同一时间。

我发现可以使用 multiprocessing.Manager，但我使用的是 concurrent.futures.ThreadPoolExecutor。有没有类似的功能？

我现在写了下面的代码来澄清一下。实际代码中有一个 setState 函数用于设置录制状态等，并且按下的键不会被传递。此外，实际代码显然有一个按键和鼠标移动的侦听器，getKey 和 getMove 函数应该是附加到列表的函数。在这种情况下的问题是，一旦按下“插入”键，就不能从应该开始记录移动的第二个进程访问记录变量。一个类似于多处理中的管理器的并发函数可以解决它，但我不确定它被称为什么或使用它。

from concurrent.futures import ThreadPoolExecutor as Executor
import time

class recMacros(object):
    def __init__(self):
        self.recording = False

        self.lastKey = None
        self.lastMove = None

        self.mouseMoves = []
        self.keyPresses = []

        self.runMacros()


    def getTime(self):
        return time.time()

    def getKey(self):
        #return keyboard listener last key pressed
        return "W"

    def getMove(self):
        #return keyboard listener last key pressed
        return "W"

    def recMoves(self): 
        while True:
            while self.recording:
                mouseMove = self.getMove()
                if mouseMove != self.lastMove:
                    self.mouseMoves.append((mouseMove, self.getTime()))
                    self.lastMove = mouseMove

    def recPresses(self):
         while True:
             keyPress = self.getKey()
             if keyPress == "Insert":
                self.recording = True
             elif keyPress == "End":
                self.recording = False
             elif self.recording and keyPress != self.lastKey:
                self.keyPresses.append((keyPress, self.getTime()))
                self.lastKey = keyPress
             else:
                 print("Error")

    def recMacros(self):
        with Executor(max_workers=2) as e:
            e.submit(recPresses)
            e.submit(recMoves)

if __name__ == "__main__":
     recMacros()

我很感激一些快速的方向，因为我很着急。提前致谢

@user2357112 支持莫妮卡 这是我用来测试时间的代码，以验证 ThreadPoolExecutor 就像一个进程来并行运行函数：

from concurrent.futures import ThreadPoolExecutor
import time

def printTime():
    print(f"Time: {time.time()}\n")


def runPro():
    with ThreadPoolExecutor(max_workers=3) as e:
        for i in range(3):
            e.submit(printTime)


runPro()

Answer 1

如果您想将某些内容保存在每个进程都可以使用的变量中，您可以使用queue。

1. 导入queue

import queue

1. 创建共享变量

shared_var = queue.Queue(maxsize=0)

其中maxsize 是此队列中可以保存的最大值

1. 在任何进程中编辑共享变量

shared_var.put(item)

4. 获取变量中的东西

variable = shared_var.get()

您可以使用queue 做更多事情，请参阅documentation。