Jellyfin/jellyfin-kodi
1
0
Fork 0
mirror of https://github.com/jellyfin/jellyfin-kodi.git synced 2024-12-25 10:16:11 +00:00
Code Issues Projects Releases Packages Wiki Activity

Review library threads

Browse source
This commit is contained in:
angelblue05 2018-10-07 18:19:06 -05:00
parent 30f066ede8
commit 69395b0e80
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
resources/lib/library.py
View file

@ -228,7 +228,7 @@ class Library(threading.Thread):
for queues in self.updated_output: for queues in self.updated_output:
queue = self.updated_output[queues] queue = self.updated_output[queues]
if queue.qsize() and len(self.writer_threads['updated']) < 4: if queue.qsize() and not len(self.writer_threads['updated']):
if queues in ('Audio', 'MusicArtist', 'AlbumArtist', 'MusicAlbum'): if queues in ('Audio', 'MusicArtist', 'AlbumArtist', 'MusicAlbum'):
new_thread = UpdatedWorker(queue, self.notify_output, self.music_database_lock, "music", self.server, self.direct_path) new_thread = UpdatedWorker(queue, self.notify_output, self.music_database_lock, "music", self.server, self.direct_path)
@ -247,7 +247,7 @@ class Library(threading.Thread):
for queues in self.userdata_output: for queues in self.userdata_output:
queue = self.userdata_output[queues] queue = self.userdata_output[queues]
if queue.qsize() and len(self.writer_threads['userdata']) < 4: if queue.qsize() and not len(self.writer_threads['userdata']):
if queues in ('Audio', 'MusicArtist', 'AlbumArtist', 'MusicAlbum'): if queues in ('Audio', 'MusicArtist', 'AlbumArtist', 'MusicAlbum'):
new_thread = UserDataWorker(queue, self.music_database_lock, "music", self.server, self.direct_path) new_thread = UserDataWorker(queue, self.music_database_lock, "music", self.server, self.direct_path)
@ -266,7 +266,7 @@ class Library(threading.Thread):
for queues in self.removed_output: for queues in self.removed_output:
queue = self.removed_output[queues] queue = self.removed_output[queues]
if queue.qsize() and len(self.writer_threads['removed']) < 2: if queue.qsize() and not len(self.writer_threads['removed']):
if queues in ('Audio', 'MusicArtist', 'AlbumArtist', 'MusicAlbum'): if queues in ('Audio', 'MusicArtist', 'AlbumArtist', 'MusicAlbum'):
new_thread = RemovedWorker(queue, self.music_database_lock, "music", self.server, self.direct_path) new_thread = RemovedWorker(queue, self.music_database_lock, "music", self.server, self.direct_path)
@ -282,7 +282,7 @@ class Library(threading.Thread):
''' Notify the user of new additions. ''' Notify the user of new additions.
''' '''
if self.notify_output.qsize() and len(self.notify_threads) < 1: if self.notify_output.qsize() and not len(self.notify_threads):
new_thread = NotifyWorker(self.notify_output, self.player) new_thread = NotifyWorker(self.notify_output, self.player)
new_thread.start() new_thread.start()