Close request queue.

This fixes multiprocessing.Queue vomiting at shutdown.

1 files changed, 1 insertions, 0 deletions

diff --git a/bgproc.py b/bgproc.py
index 3a1e726..8339230 100644
--- a/bgproc.py
+++ b/bgproc.py
@@ -59,6 +59,7 @@ class BackgroundProcessing(object):
         '''
         for p in self.processes:
             self.requests.put(None)
+        self.requests.close()
 
     def finish(self):
         '''Wait until all children have finished.'''