Add max_threads

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

.env.sample

@@ -18,6 +18,12 @@ SLEEP_DURATION = "3600"
 ## Log file where all output will be written to
 LOGFILE = "log.log"
 
+## Timeout for requests for jellyfin
+REQUEST_TIMEOUT = 300
+
+## Max threads for processing
+MAX_THREADS = 32
+
 ## Map usernames between servers in the event that they are different, order does not matter
 ## Comma separated for multiple options
 #USER_MAPPING = { "testuser2": "testuser3", "testuser1":"testuser4" }

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(int(os.getenv("MAX_THREADS", 32)), os.cpu_count() * 2, threads)
-        workers = min(32, os.cpu_count() * 2)
 
     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