| | |
| | | import logging |
| | | import queue |
| | | import threading |
| | | import time |
| | | |
| | | from log_module.log import logger_l2_process_time, logger_debug |
| | | from huaxin_client import l1_subscript_codes_manager |
| | | from log_module.log import logger_debug |
| | | |
| | | _dict = {} |
| | | |
| | |
| | | start_time = time.time() |
| | | _queue.put(index) |
| | | end_time = time.time() |
| | | logger_debug.debug(end_time -start_time) |
| | | logger_debug.debug(end_time - start_time) |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | for k in range(1): |
| | | _dict.clear() |
| | | for i in range(0, 1000): |
| | | threading.Thread(target=lambda: add(i), daemon=True).start() |
| | | time.sleep(2) |
| | | |
| | | input() |
| | | # l1_subscript_codes_manager.save_codes(["600100", "600102"], ["000123", "000146"]) |
| | | code_sh,codes_sz =l1_subscript_codes_manager.request_l1_subscript_target_codes() |
| | | l1_subscript_codes_manager.save_codes(code_sh,codes_sz) |