From 41a9e08155cc561803cddbb95fbfb616525619af Mon Sep 17 00:00:00 2001 From: echel0n Date: Sun, 1 Jun 2014 18:16:25 -0700 Subject: [PATCH] Added thread locking for sorting queue's --- sickbeard/generic_queue.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/sickbeard/generic_queue.py b/sickbeard/generic_queue.py index f426a222..8be859cf 100644 --- a/sickbeard/generic_queue.py +++ b/sickbeard/generic_queue.py @@ -41,6 +41,8 @@ class GenericQueue(object): self.currentItem = None + self.lock = threading.Lock() + def pause(self): logger.log(u"Pausing queue") self.min_priority = 999999999999 @@ -83,7 +85,8 @@ class GenericQueue(object): else: return y.priority-x.priority - self.queue.sort(cmp=sorter) + with self.lock: + self.queue.sort(cmp=sorter) queueItem = self.queue[0]