GetStockQuoteInfoAsDataFrame 및 Real Data 호출을 두번째 할때 Deadlock 걸리는 현상문의

[floatingCode21]

안녕하세요,
GetStockQuoteInfoAsDataFrame()을 통해 주가정보를 dataframe으로 가져온후
Real Data를 요청하여 dataframe의 정보들이 지속적으로 업데이트 되는 로직을 구현해보고 있습니다.
그런데, Real Data 요청을 중지하고 다시 GetStockQuoteInfoAsDataFrame을 통해 dataframe을 가져오려고 하면
Deadlock 걸리듯이 GetStockQuoteInfoAsDataFrame에서 멈춰버리내요.(main logic 참조)
현상을 해결할수있는 도움을 받을수 있는지 문의 드립니다.

class RealDataThread(threading.Thread):

    def stop(self):
        self.stream.cancel()

    def run(self):
        self.stream = entrypoint.GetRealDataForCodesAsStream(code_list,
                                                             fid_list,
                                                             real_type,
                                                             screen_no=self.name,
                                                             infer_fids=True,
                                                             readable_names=True,
                                                             fast_parse=False)
        try:
            self.lock.acquire()
            for i, event in enumerate(self.stream):
                do_something()...
        except grpc.RpcError as e:
            print(e)
            pass

class EntryPointInferface:

    def getBasicStockInfo(self, code_list):
        df = self.entrypoint.GetStockQuoteInfoAsDataFrame(code_list)
        realDataThread.start() 

#main logic

#request data frame and real data
entryPointInferface.getBasicStockInfo(code_list)
#time delay 10 sec
#real data stop
realDataThread.stop() 

#request data frame and real data, again.
#but blocked when calling GetStockQuoteInfoAsDataFrame()
entryPointInferface.getBasicStockInfo(code_list)

[elbakramer]

주신것만으로는 잘 모르겠습니다.

혹시 통채로 돌려볼만한 스크립트는 없나요?
실제 사용하신 변수값이라던가 서버생성방식, 서버로그 등등이 궁금하네요.

데드락이 걸릴만한게 잘 상상이 안갑니다.
특히 실시간이랑 일반TR 요청사이에는 더욱 접접이 없을거라 서로 락걸릴만한건 딱히 없는데..
그냥 트레이 서버가 죽는다거나 아님 다른 코드상 이슈지 않을까 싶어요.
저는 self.lock.acquire() 저게 의심가는데.. 저거 왜 필요한거에요?

이외에 하나 이상한거는 getBasicStockInfo() 두 번 호출하시면서 threading.Thread.start() 를 두 번 호출하시는데,
이거 두 번 이상 호출하면 에러가 날건데요 (링크). 이거는 이슈 없던가요?
해당 에러를 못보신거면 진짜 그 바로앞에서 멈춰버려서 에러까지 못간건가.. 하고 납득이 되긴 하네요.

[elbakramer]

해당 내용 #36, #40, #41 등과 관련이 있어보이는데, 한번 확인해보세요.