1 files changed, 47 insertions, 0 deletions
diff --git a/bgproc.py b/bgproc.py
new file mode 100644
index 0000000..6f7c4c5
--- /dev/null
+++ b/bgproc.py
@@ -0,0 +1,47 @@
+# Copyright 2011  Lars Wirzenius
+# 
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+# 
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+# 
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+
+class BackgroundProcessing(object):
+
+    '''Manage background processing queues.'''
+    
+    def __init__(self, func):
+        self.pending_requests = 0
+        
+    def enqueue_request(self, request):
+        '''Put a request into queue, to be processed by workers whenever.'''
+        
+    def close_requests(self):
+        '''Signal workers that they can retire.
+        
+        All pending requests will be processed, but after the queue
+        is empty, the workers will finish. No more requests may be
+        enqueued.
+        
+        '''
+        
+    def wait_for_results(self):
+        '''Block until there are results available.
+
+        No blocking if results are already available.
+        Return True if there are results available,
+        False if there will be no more results,
+        because all requests have been processed.
+        
+        '''
+
+    def __iter__(self):
+        '''Iterate over immediately available results.'''