파이썬 스레드 싱크

Question

Update이라는 빈 메서드가있는 기본 클래스가 있습니다. 이 Update 메서드는 다른 양의 서브 클래스가 X만큼 상속됩니다 기본 클래스는 Update 메서드를 30 틱마다 한 번 호출합니다 (지금 당장은 루프로 처리하고 있지만 30 개마다 호출하도록 할 계획입니다). 곧 바뀔 것입니다. 각 하위 클래스에는 고유 한 지침 집합이있는 Update 메서드가 있습니다. 잘 작동합니다. 그러나 한 가지 문제가 있으며 모든 스레드가 서로 충돌합니다. 파이썬 셸에서 메시지를 출력하면 함께 섞이게됩니다.

나는 그것에 대한 연구를 해왔지만, 내가 발견 한 것으로부터 나에게서 혼란 스러울만큼 혼란 스럽다. 모두 내가하고 싶은 obj1, obj2 및 obj3 자신의 라인의 출력을 가지고 함께 분쇄하지 않습니다.

다음은 다중 스레드 잠금 객체 인 semaphore이다 필요한 것은 내 현재 코드

import _thread 
class BaseClass(object): 
    def __init__(self, name): 
     self.name = name 
     _thread.start_new_thread(self.UpdateHandler,()) 

    def ClassType(self): 
     """Returns a string of the childs type""" 
     pass 

    def UpdateHandler(self): 
     #this part handles when to call the update. 
     #it is allso needed so that it can be run in a thread. 
     while True: 
      self.Update() 

    def Update(self): 
     #This is a place holder. 
     #It stops classes that dont have a Update function crashing when called 
     pass 

#--------------------------------------------------------------------------------- 
class ChildClassA(BaseClass): 
    def __init__(self, name): 
     super(ChildClassA, self).__init__(name) 

    def ClassType(self): 
     return 'ChildClassA' 

    def Update(self): 
     print(self.name, ": is doing stuff CLASS A") 

#---------------------------------------------------------------------------------- 
class ChildClassB(BaseClass): 
    def __init__(self, name): 
     super(ChildClassB, self).__init__(name) 

    def Update(self): 
     print(self.name, "This is a completley diffeent action CLASS B") 
     self.Hi() 

    def ClassType(self): 
     return 'ChildClassB' 

    def Hi(self): 
     print("Hi") 
#---------------------------------------------------------------------------------- 
class ChildClassC(BaseClass): 
    def __init__(self, name): 
     super(ChildClassC, self).__init__(name) 

    def Update(self): 
     print(self.name, "This is a completley diffeent action") 

#-------------------------------------------------------------------------------- 

obj1 = ChildClassA('Obj1') 
obj2 = ChildClassA('Obj2') 
obj3 = ChildClassB('Obj3') 

Answer 1

입니다. https://en.wikipedia.org/wiki/Semaphore_(programming).

당신은 유치원이나 유치원에서 화장실에 가야 할 곳과 같은 원칙을 보게되는 경우가 있는데, 화장실을 점유하고 있지 않다는 것을 나타내는 목걸이 또는 다른 물건을 가져 가야합니다.

세마포어 개체에는 전통적으로 P 및 V이라는 두 가지 작업이 있습니다. P 작업은 잠금을 요청합니다. 현재 잠금이 수행되면 잠금은 잠금이 해제 될 때까지 대기합니다. V 작업은 잠금을 해제하므로 다른 스레드가 잠금을 설정할 수 있습니다. P 및 V은 네덜란드어 단어 "plaatsen"en "vrijgeven"("put"및 "release")의 약자입니다.

파이썬에서는 threading.Semaphore() 또는 _thread.request_lock() 팩토리 기능을 사용하여 세마포어 개체를 만들 수 있습니다. 결과 객체에는 acquire (= P) 및 release (= V)의 두 가지 메소드가 있습니다.

import _thread 
class BaseClass(object): 
    lock = _thread.request_lock() 
    def __init__(self, name): 
     self.name = name 
     _thread.start_new_thread(self.UpdateHandler,()) 

    def ClassType(self): 
     """Returns a string of the childs type""" 
     pass 

    def UpdateHandler(self): 
     #this part handles when to call the update. 
     #it is allso needed so that it can be run in a thread. 
     while True: 
      self.lock.acquire() 
      self.Update() 
      self.lock.release() 


    def Update(self): 
     #This is a place holder. 
     #It stops classes that dont have a Update function crashing when called 
     pass