现在我有一个工作程序，它正在监视一个目录，寻找一个特定命名的文件。当文件出现在这个目录中时，代码将其名称更改为其他名称，然后在另一个进程中执行一些函数，以便同时处理多个文件（下面的代码可能比我蹩脚的英语更好地解释它）。我需要改变这种方式，这些文件被添加和存储在队列中，我可以限制并发工作的文件数量。
示例性电流代码：

Class WorkOnFiles(multiprocessing.Process):
   def __init__(self, filename):

   ...

   def run(self):
      #do something on files

directory = "/path/to/directory"

while True:
   for filename in os.listdir(directory):
      if filename.startswith("ABC"):
         new_filename = "XYZ" + filename
         os.system(f"mv {filename} {new_filename}")
         WorkOnFiles(new_filename).start()

我希望新的代码工作类似（最好不要改变“WorkOnFiles”类），但限制并发进程的数量，而这些文件的工作，新的文件被添加到某种队列等待轮到他们。类似这样的东西（下面是破碎的伪代码，只是为了展示我想象的样子）：

workers = create_workers(num_of_workers = 2)
queue = make_queue()

while True:
   for filename in os.listdir(directory):
      if filename.startswith("ABC"):
         new_filename = "XYZ" + filename
         os.system(f"mv {filename} {new_filename}")
       
        
         queue.add(new_filename)

      if there is an idle worker and queue not empty:
         workers.run(WorkOnFiles(queue.get()).start())
      time.sleep(1)

因此，这段代码将创建2个worker--可以同时运行的进程。每一秒它都会检查ABC文件是否出现，它会将其新名称添加到队列中，接下来如果至少有一个空闲工作者并且队列不为空，它会启动一个新进程来处理此文件。我尝试过不同的方法，但我真的不能理解多处理是如何。队列和和多处理包工作。