From 7041448c825eaa3643ac74d5570cc373d2adb142 Mon Sep 17 00:00:00 2001
From: Ethan Dalool <ethan@voussoir.net>
Date: Wed, 12 Feb 2020 19:11:24 -0800
Subject: [PATCH] Make pool._jobs private to discourage outside editing.

---
 voussoirkit/threadpool.py | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/voussoirkit/threadpool.py b/voussoirkit/threadpool.py
index cf0e6f7..4bb4990 100644
--- a/voussoirkit/threadpool.py
+++ b/voussoirkit/threadpool.py
@@ -30,7 +30,7 @@ class ThreadPool:
         self.max_size = size
         self.closed = False
         self.paused = paused
-        self.jobs = []
+        self._jobs = []
         self.job_manager_lock = threading.Lock()
 
     def _clear_done_jobs(self):
@@ -38,7 +38,7 @@ class ThreadPool:
         This function assumes that job_manager_lock is acquired!!
         You should call clear_done_and_start_jobs instead!
         '''
-        self.jobs[:] = [j for j in self.jobs if j.status in {PENDING, RUNNING}]
+        self._jobs[:] = [j for j in self._jobs if j.status in {PENDING, RUNNING}]
 
     def _start_jobs(self):
         '''
@@ -50,7 +50,7 @@ class ThreadPool:
         if available == 0:
             return
         # print(f'Gonna start me some {available} jobs.')
-        for job in list(self.jobs):
+        for job in list(self._jobs):
             if job.status == PENDING:
                 # print('starting', job)
                 job.start()
@@ -106,7 +106,7 @@ class ThreadPool:
             args=args,
             kwargs=kwargs,
         )
-        self.jobs.append(job)
+        self._jobs.append(job)
 
         if not self.paused:
             self._clear_done_and_start_jobs()
@@ -134,7 +134,7 @@ class ThreadPool:
             kwargs.pop('pool', None)
             job = Job(pool=self, **kwargs)
             these_jobs.append(job)
-            self.jobs.append(job)
+            self._jobs.append(job)
 
         if not self.paused:
             self._clear_done_and_start_jobs()
@@ -166,14 +166,14 @@ class ThreadPool:
         '''
         self.closed = True
         self.clear_done_and_start_jobs()
-        for job in self.jobs:
+        for job in self._jobs:
             job.join()
 
     def running_count(self):
-        return sum(1 for job in list(self.jobs) if job.status is RUNNING)
+        return sum(1 for job in list(self._jobs) if job.status is RUNNING)
 
     def unfinished_count(self):
-        return sum(1 for job in list(self.jobs) if job.status in {PENDING, RUNNING})
+        return sum(1 for job in list(self._jobs) if job.status in {PENDING, RUNNING})
 
 class Job:
     def __init__(self, pool, function, *, name=None, args=tuple(), kwargs=dict()):