如何知道队列中的特定任务是否完成？

Question

我对 python 队列有疑问。

我写了一个线程类，它的run()方法执行队列。

  import threading
  import Queue

  def AThread(threading.Thread):
     def __init__(self,arg1):
         self.file_resource=arg1
         threading.Thread.__init__(self)
         self.queue=Queue.Queue()

     def __myTask(self):
         self.file_resource.write()
         ''' Method that will access a common resource
          Needs to be synchronized.
          Returns a Boolean based on the outcome
         '''

     def run():
         while True:
             cmd=self.queue.get()
             #cmd is actually a call to method
             exec("self.__"+cmd)
             self.queue.task_done()


 #The problem i have here is while invoking the thread
 a=AThread()
 a.queue.put("myTask()")
 print "Hai"

同一个 AThread 实例 (a=AThread()) 会将任务从不同位置加载到队列中。

因此底部的 print 语句应该等待通过上面的语句添加到队列中的任务，并等待一个确定的时间，并在执行任务后接收返回的值。

有没有一种简单的方法来实现这一点？我对此进行了很多搜索，请查看此代码并提供建议。

以及为什么python的获取和释放锁不在类的实例上。在上述场景中，AThread 的实例 a 和 b 不需要同步，但是当应用获取和释放锁时，myTask 会为 a 和 b 的两个实例同步运行。

请提供建议。

Answer 1

您可以采取多种方法，具体取决于您的问题的具体情况。

如果您的print "Hai" 只需要在 myTask 完成后发生，您可以将其放入一个任务中，并让 myTask 在完成时将该任务放入队列中。 （如果你是 CS 理论类的人，你可以认为这类似于 continuation-passing 风格）。

如果您的 print "Hai" 对多个任务有更复杂的依赖，您可能会考虑期货或承诺。

您可以进入基于 Actor 的并发世界，在这种情况下，可能会有一个同步消息发送方法或多或少地完成您想要的操作。

如果您不想使用期货或承诺，您可以手动实现类似的事情，方法是引入条件变量。在 myTask 启动之前设置条件变量并将其传递给 myTask，然后等待它被清除。随着程序的增长，您必须非常小心，并不断重新考虑您的锁定策略，以确保它保持简单和易于理解 - 这就是造成困难并发错误的原因。

获得所需内容的最小明智步骤可能是提供 Queue.put() 的阻塞版本，它执行条件变量的事情。确保您考虑是否要阻塞直到队列为空，或者直到您放入队列的内容从队列中删除，或者直到您放入队列的内容完成处理。然后确保您实施您在考虑时决定实施的事情。