From 7310536a3d5e3c3ee5a80304ca11d8709f46ecce Mon Sep 17 00:00:00 2001
From: Kenneth Reitz <me@kennethreitz.org>
Date: Sat, 2 Sep 2017 18:12:47 -0400
Subject: [PATCH] basics working

Signed-off-by: Kenneth Reitz <me@kennethreitz.org>
---
 background.py | 46 ++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 46 insertions(+)
 create mode 100644 background.py

diff --git a/background.py b/background.py
new file mode 100644
index 0000000..7905650
--- /dev/null
+++ b/background.py
@@ -0,0 +1,46 @@
+#!/usr/bin/env python
+
+import multiprocessing
+import concurrent.futures
+
+from decorator import decorator
+
+
+class Worker(object):
+    """A Background Worker."""
+
+    def __init__(self, n=None, use_subprocess=False):
+        self.n = n
+        self.use_subprocess = use_subprocess
+
+        self.configure_n()
+
+        if self.uses_subprocess:
+            self.pool = concurrent.futures.ProcessPoolExecutor(max_workers=self.n)
+        else:
+            self.pool = concurrent.futures.ThreadPoolExecutor(max_workers=self.n)
+
+    @property
+    def uses_threads(self):
+        return not self.uses_subprocess
+
+    @property
+    def uses_subprocess(self):
+        return self.use_subprocess
+
+    def configure_n(self):
+        if self.n is None:
+            self.n = multiprocessing.cpu_count()
+
+    # @decorator
+    def run(self, f, *args, **kwargs):
+        self.pool.submit(f, *args, **kwargs)
+
+
+default_worker = Worker()
+
+
+@decorator
+def task(f, *args, **kwargs):
+    return default_worker.run(f)
+