Add max_threads

Signed-off-by: Luigi311 <git@luigi311.com>

src/functions.py

@@ -63,12 +63,11 @@ def search_mapping(dictionary: dict, key_value: str):
         return None
 
 
-def future_thread_executor(args: list, workers: int = -1):
+def future_thread_executor(args: list, threads: int = 32):
     futures_list = []
     results = []
 
-    if workers == -1:
-        workers = min(32, os.cpu_count() * 2)
+    workers = min(int(os.getenv("MAX_THREADS", 32)), os.cpu_count() * 2, threads)
 
     with ThreadPoolExecutor(max_workers=workers) as executor:
         for arg in args:

src/plex.py

@@ -174,7 +174,7 @@ def get_user_library_watched(user, user_plex, library):
                 args.append([get_user_library_watched_show, show])
 
             for show_guids, episode_guids in future_thread_executor(
-                args, workers=min(os.cpu_count(), 4)
+                args, threads=4
             ):
                 if show_guids and episode_guids:
                     # append show, season, episode