river_tao/OneForAll-mirror
1
0
Fork 0
mirror of https://github.com/shmilylty/OneForAll.git synced 2026-10-25 00:56:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

设置为守护线程

Browse Source
This commit is contained in:
Jing Ling
2020-08-26 23:39:41 +08:00
parent 9df44674bb
commit 0b8ae0659d
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/request.py
+5 -3
View File
@@ -173,11 +173,13 @@ def bulk_request(urls):
thread_count = req_thread_count() thread_count = req_thread_count()
bar = get_progress_bar(total) bar = get_progress_bar(total)
progress_thread = Thread(target=progress, args=(bar, total, urls_queue)) progress_thread = Thread(target=progress, name='ProgressThread',
args=(bar, total, urls_queue), daemon=True)
progress_thread.start() progress_thread.start()
for _ in range(thread_count): for i in range(thread_count):
request_thread = Thread(target=request, args=(urls_queue, resp_queue, session)) request_thread = Thread(target=request, name=f'RequestThread-{i}',
args=(urls_queue, resp_queue, session), daemon=True)
request_thread.start() request_thread.start()
urls_queue.join() urls_queue.join()