1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
| 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))
|
|
