import multiprocessing
import queue
import threading
import time

from huaxin_client import l2_data_manager
from log_module import async_log_util
from log_module.log import logger_debug

__queue = queue.Queue()


def start_thread():
    print(threading.current_thread().getName(), threading.current_thread().ident)


if __name__ == "__main__":
    _queue = queue.Queue()
    _queue.put("123123")
    print(_queue.get(False))
    print(_queue.get(False))