대기열의 특정 작업이 완료되었는지 확인하는 방법은 무엇입니까?

Question

파이썬 대기열에 관해서는 의심 스럽습니다.

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 문은 위의 명령문을 통해 대기열에 추가 된 작업을 기다린 후 최종 기간 동안 대기해야하며 작업 실행 후 반환 된 값도 수신해야합니다.

이 작업을 수행하는 간단한 방법이 있습니까? 나는 이것에 관해 많은 것을 수색하고,이 코드를 친절하게 검토하고 격렬한 이야기를 제공한다.

왜 파이썬의 획득 및 해제 잠금이 클래스의 인스턴스에 없는지? 언급 된 시나리오에서 AThread의 인스턴스 a와 b는 동기화 될 필요가 없지만 획득 및 릴리스 잠금이 적용될 때 myTask는 a와 b의 두 인스턴스에 대해 동기화되어 실행됩니다.

친절하게 제안합니다.

Answer 1

문제의 특정 윤곽에 따라 취할 수있는 방법이 많이 있습니다.

print "Hai"이 myTask가 완료된 후에 만 ​​발생해야하는 경우 작업에 넣을 수 있으며 myTask가 완료되면 해당 작업을 대기열에 넣을 수 있습니다. (만약 당신이 CS 이론과 같은 사람이라면, 이것을 연속 - 통과 스타일과 유사하다고 생각할 수 있습니다.)

print "Hai"에 여러 작업에 대한보다 정교한 의존성이있는 경우 미래 ​​또는 약속을 조사 할 수 있습니다.

당신은 액터 기반 동시성의 세계로 한 발짝을 옮길 수 있습니다.이 경우, 당신이 원하는 것보다 더 많거나 적은 동기식 메시지 전송 방법이있을 것입니다.

선물이나 약속을 사용하고 싶지 않은 경우 조건 변수를 도입하여 수동으로 비슷한 결과를 얻을 수 있습니다. myTask가 시작되기 전에 조건 변수를 설정하고 myTask로 전달한 다음이 변수가 지워질 때까지 기다립니다. 프로그램이 성장함에 따라 매우 신중해야하며 잠금 전략을 지속적으로 다시 생각하여 간단하고 이해하기 쉽도록 유지해야합니다. 이는 어려운 동시성 버그가 발생하는 것입니다.

원하는 것을 얻는 가장 작은 합리적인 단계는 아마도 조건 변수를 수행하는 Queue.put()의 차단 버전을 제공하는 것입니다. 대기열이 비어있을 때까지 또는 대기열에 넣은 것이 제거 될 때까지 또는 대기열에 넣은 것이 처리를 마칠 때까지 차단할지 여부를 생각하십시오. 그리고 나서 생각할 때 구현하기로 결정한 것을 구현해야합니다.