concurrent/thread: add pool parameter tests

Signed-off-by: Matteo Cafasso <[email protected]>

Author: noxdafox

test/test_concurrent_thread.py

@@ -2,6 +2,7 @@
 import threading
 
 from pebble import concurrent
+from pebble import ThreadPool
 
 
 def not_decorated(argument, keyword_argument=0):
@@ -44,6 +45,11 @@ def daemon_keyword_decorated():
     return threading.current_thread().daemon
 
 
+@concurrent.thread(pool=ThreadPool(1))
+def pool_decorated(_argument, _keyword_argument=0):
+    return threading.current_thread().ident
+
+
 class ThreadConcurrentObj:
     a = 0
 
@@ -130,7 +136,7 @@ def test_error_returned(self):
         self.assertIsInstance(future.result(), RuntimeError)
 
     def test_error_decorated_callback(self):
-        """Thread  errors are forwarded to callback."""
+        """Thread errors are forwarded to callback."""
         future = error_decorated()
         future.add_done_callback(self.callback)
         self.event.wait(timeout=1)
@@ -163,3 +169,9 @@ def test_daemon_keyword_decorated(self):
         f = daemon_keyword_decorated()
         dec_out = f.result()
         self.assertEqual(dec_out, False)
+
+    def test_pool_decorated(self):
+        """Thread pool decorated function."""
+        future1 = pool_decorated(1, 1)
+        future2 = pool_decorated(1, 1)
+        self.assertEqual(future1.result(), future2.result())