From 84c2aa7fa0e9a119f1301d864d5ae4b1ae1ae5dd Mon Sep 17 00:00:00 2001
From: Croneter <kathriner.thomas@gmail.com>
Date: Fri, 18 May 2018 15:59:26 +0200
Subject: [PATCH] Reduce CPU strain for artwork caching progress

- Fixes #477
---
 resources/lib/artwork.py             | 21 ++++++++++-----------
 resources/lib/library_sync/fanart.py | 23 ++++++++++-------------
 2 files changed, 20 insertions(+), 24 deletions(-)

diff --git a/resources/lib/artwork.py b/resources/lib/artwork.py
index 68900baf..f95d2b16 100644
--- a/resources/lib/artwork.py
+++ b/resources/lib/artwork.py
@@ -65,23 +65,17 @@ class Image_Cache_Thread(Thread):
                     LOG.info("---===### Stopped Image_Cache_Thread ###===---")
                     return
                 sleep(1000)
-            # Update the caching state in the PKC settings. Avoid saving '0'
-            counter += 1
-            if counter > 10:
-                counter = 0
-                length = queue.qsize()
-                if not set_zero:
-                    settings('caching_artwork_count', value=str(length))
-                    set_zero = False if length else True
-                elif length:
-                    settings('caching_artwork_count', value=str(length))
-                    set_zero = False
 
             try:
                 url = queue.get(block=False)
             except Empty:
+                if not set_zero:
+                    # Avoid saving '0' all the time
+                    set_zero = True
+                    settings('caching_artwork_count', value='0')
                 sleep(1000)
                 continue
+            set_zero = False
             if isinstance(url, ArtworkSyncMessage):
                 if state.IMAGE_SYNC_NOTIFICATIONS:
                     dialog('notification',
@@ -133,6 +127,11 @@ class Image_Cache_Thread(Thread):
                 # We did not even get a timeout
                 break
             queue.task_done()
+            # Update the caching state in the PKC settings.
+            counter += 1
+            if counter > 20:
+                counter = 0
+                settings('caching_artwork_count', value=str(queue.qsize()))
             # Sleep for a bit to reduce CPU strain
             sleep(sleep_between)
         LOG.info("---===### Stopped Image_Cache_Thread ###===---")
diff --git a/resources/lib/library_sync/fanart.py b/resources/lib/library_sync/fanart.py
index 9231af86..fddb6b82 100644
--- a/resources/lib/library_sync/fanart.py
+++ b/resources/lib/library_sync/fanart.py
@@ -60,25 +60,17 @@ class ThreadedProcessFanart(Thread):
                     LOG.info("---===### Stopped FanartSync ###===---")
                     return
                 sleep(1000)
-            # Update the caching state in the PKC settings. Avoid saving '0'
-            counter += 1
-            if counter > 10:
-                counter = 0
-                length = queue.qsize()
-                if not set_zero:
-                    settings('fanarttv_lookups', value=str(length))
-                    set_zero = False if length else True
-                elif length:
-                    settings('fanarttv_lookups', value=str(length))
-                    set_zero = False
-
             # grabs Plex item from queue
             try:
                 item = queue.get(block=False)
             except Empty:
+                if not set_zero:
+                    # Avoid saving '0' all the time
+                    set_zero = True
+                    settings('fanarttv_lookups', value='0')
                 sleep(200)
                 continue
-
+            set_zero = False
             if isinstance(item, ArtworkSyncMessage):
                 if state.IMAGE_SYNC_NOTIFICATIONS:
                     dialog('notification',
@@ -98,5 +90,10 @@ class ThreadedProcessFanart(Thread):
                 LOG.debug('Done getting fanart for Plex id %s', item['plex_id'])
                 with plexdb.Get_Plex_DB() as plex_db:
                     plex_db.set_fanart_synched(item['plex_id'])
+            # Update the caching state in the PKC settings. Avoid saving '0'
+            counter += 1
+            if counter > 10:
+                counter = 0
+                settings('fanarttv_lookups', value=str(queue.qsize()))
             queue.task_done()
         LOG.debug("---===### Stopped FanartSync ###===---")