forked from DRMTalks/devine
Merge pull request 'master' (#3) from DRMTalks/devine:master into master
Reviewed-on: #3
This commit is contained in:
commit
2d7440ed95
|
@ -1,4 +1,5 @@
|
||||||
import math
|
import math
|
||||||
|
import os
|
||||||
import time
|
import time
|
||||||
from concurrent import futures
|
from concurrent import futures
|
||||||
from concurrent.futures.thread import ThreadPoolExecutor
|
from concurrent.futures.thread import ThreadPoolExecutor
|
||||||
|
@ -196,6 +197,9 @@ def requests(
|
||||||
if not isinstance(urls, list):
|
if not isinstance(urls, list):
|
||||||
urls = [urls]
|
urls = [urls]
|
||||||
|
|
||||||
|
if not max_workers:
|
||||||
|
max_workers = min(32, (os.cpu_count() or 1) + 4)
|
||||||
|
|
||||||
urls = [
|
urls = [
|
||||||
dict(
|
dict(
|
||||||
save_path=save_path,
|
save_path=save_path,
|
||||||
|
@ -214,7 +218,8 @@ def requests(
|
||||||
session = Session()
|
session = Session()
|
||||||
session.mount("https://", HTTPAdapter(
|
session.mount("https://", HTTPAdapter(
|
||||||
pool_connections=max_workers,
|
pool_connections=max_workers,
|
||||||
pool_maxsize=max_workers
|
pool_maxsize=max_workers,
|
||||||
|
pool_block=True
|
||||||
))
|
))
|
||||||
session.mount("http://", session.adapters["https://"])
|
session.mount("http://", session.adapters["https://"])
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue