console.py

import multiprocessing
import threading
import time


class ServerConsole:
    def __init__(self):
        self.msg_queue = multiprocessing.Queue()

        self.console_process = threading.Thread(target=self.console, args=(self.msg_queue,))
        self.console_process.start()

    def print(self, msg: str):
        self.msg_queue.put(msg)

    def console(self, queue):
        input_process = threading.Thread(target=self.wait_input, args=(queue,))
        input_process.start()

        while True:
            while not queue.empty():

                if input_process is not None:
                    input_process.terminate()
                    input_process = None
                    print('\r', end='')

                print('server log:', queue.get())
            # time.sleep(0.2)

            if input_process is None:
                input_process = threading.Thread(target=self.wait_input, args=(queue,))
                input_process.start()

    def wait_input(self, queue):
        try:
            cmd = input('>> ')
            print('!!!!!!!!!!!!')
            print('!!!!!!!!!!!!')
            print('!!!!!!!!!!!!')
            self.msg_queue.put(cmd)
            queue.put(cmd)
        except EOFError:
            pass


if __name__ == '__main__':
    c = ServerConsole()

    for _ in range(10):
        time.sleep(5)
        c.print('test')