Skip to content

Commit

Permalink
Fix ThreadPool and Worker class in thread_pool.py
Browse files Browse the repository at this point in the history
Change Worker daemon field to True.
remove queue self.task_queue size restriction in ThreadPool class.

Fixes #595
  • Loading branch information
nnehdi committed Feb 26, 2018
1 parent 4b9572a commit 8221328
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions minio/thread_pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ def __init__(self, tasks_queue, results_queue, exceptions_queue):
self.tasks_queue = tasks_queue
self.results_queue = results_queue
self.exceptions_queue = exceptions_queue
self.daemon = False
self.daemon = True
self.start()

def run(self):
Expand All @@ -61,7 +61,7 @@ class ThreadPool:
def __init__(self, num_threads):
self.results_queue = queue()
self.exceptions_queue = queue()
self.tasks_queue = queue(num_threads)
self.tasks_queue = queue()
self.num_threads = num_threads

def add_task(self, func, *args, **kargs):
Expand Down

0 comments on commit 8221328

Please sign in to comment.