X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=daklib%2Fthreadpool.py;h=41ae34319a1c004155a20217454c97384fa396bf;hb=57619bfe35eba89e6b0f2d2383e91590ff156763;hp=95a14a34de99218c97c2754418970d64fdb34a77;hpb=30177206e6e4fed04e77e2f4996e491cab2f9ce5;p=dak.git

diff --git a/daklib/threadpool.py b/daklib/threadpool.py
index 95a14a34..41ae3431 100644
--- a/daklib/threadpool.py
+++ b/daklib/threadpool.py
@@ -1,16 +1,13 @@
 import threading
 from time import sleep
 
+from daklib.config import Config
+
 # This code is a modified copy of
 # http://code.activestate.com/recipes/203871-a-generic-programming-thread-pool/
 # and is licensed under the Python License. The full text of the license
 # is available in the file COPYING-PSF.
 
-# FIXME:
-# numThreads defaults to 16 in __init__ to work best on
-# franck.debian.org but the default value should be specified in
-# dak.conf
-
 # Ensure booleans exist (not needed for Python 2.2.1 or higher)
 try:
     True
@@ -21,10 +18,11 @@ except NameError:
 class ThreadPool:
 
     """Flexible thread pool class.  Creates a pool of threads, then
-    accepts tasks that will be dispatched to the next available
-    thread."""
+    accepts tasks that will be dispatched to the next available thread.
+    The argument numThreads defaults to 'Common::ThreadCount' which must
+    be specified in dak.conf."""
 
-    def __init__(self, numThreads = 16):
+    def __init__(self, numThreads = Config()['Common::ThreadCount']):
 
         """Initialize the thread pool with numThreads workers."""