set DTHREADS as semaphore size

This commit is contained in:
mammo0 2020-11-02 09:40:13 +01:00 committed by GitHub
parent e510097193
commit 5522c93458
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -284,7 +284,7 @@ def _get_items(query, server_id=None):
jobs = {}
# semaphore to avoid fetching complete library to memory
thread_buffer = threading.Semaphore(LIMIT * DTHREADS)
thread_buffer = threading.Semaphore(DTHREADS)
# wrapper function for _get that uses a semaphore
def get_wrapper(params):