Troplo/PlexKodiConnect
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

New class to run functions as tasks

Browse source
This commit is contained in:
croneter 2018-11-24 09:53:37 +01:00
parent c25d6bee48
commit 69b7f91542
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
resources/lib/backgroundthread.py
View file

@ -160,6 +160,17 @@ class Task(object):
return not self.finished and not self._canceled return not self.finished and not self._canceled
def FunctionAsTask(Task):
def __init__(self, function, *args, **kwargs):
self.function = function
self._args = args
self._kwargs = kwargs
super(FunctionAsTask, self).__init__()
def run(self):
self.function(*self._args, **self._kwargs)
class MutablePriorityQueue(Queue.PriorityQueue): class MutablePriorityQueue(Queue.PriorityQueue):
def _get(self, heappop=heapq.heappop): def _get(self, heappop=heapq.heappop):
self.queue.sort() self.queue.sort()