# -*- coding: utf-8 -*-import threadingimport sysimport osimport timeimport multiprocessing

def get_input(file_no, queue_motp):    stdin_obj = os.fdopen(file_no)    code = stdin_obj.readline().strip()    queue_motp.put(code)    stdin_obj.close()

class GetMOTP(threading.Thread):    def __init__(self):        threading.Thread.__init__(self)

    def run(self):        global flag        self.motp_input_done = False        sys.stdout.write("motp>")        manager = multiprocessing.Manager()        self.queue_motp = queue_motp = manager.Queue()
        p = multiprocessing.Process(target=get_input, args=(sys.stdin.fileno(), queue_motp))    # 读取标准输入        p.start()        threading.Thread(target=self.check_from_disk).start()    # 本地读取        while queue_motp.empty():            time.sleep(0.1)        self.motp_input_done = True        p.terminate()        motp = queue_motp.get_nowait()        print("motp: ", motp)        if motp == "good":            flag = True
    # 模拟扫码逻辑    def check_from_disk(self):        while not self.motp_input_done:            if os.path.exists("motp.txt"):                with open("motp.txt", "r") as f:                    code = f.read()                    if code.strip():                        self.queue_motp.put(code.strip())                        return True            time.sleep(0.2)

if __name__ == '__main__':    GetMOTP().start()