pool: First version which works as expected in async mode. Its just using a single task for now, but next up are dependent tasks

1 files changed, 9 insertions, 10 deletions

diff --git a/test/git/async/test_thread.py b/test/git/async/test_thread.py
index 2ea8d1ff..a08c1dc7 100644
--- a/test/git/async/test_thread.py
+++ b/test/git/async/test_thread.py
@@ -3,28 +3,26 @@
 from test.testlib import *
 from git.async.thread import *
 from Queue import Queue
+import time
 
 class TestWorker(WorkerThread):
 	def __init__(self, *args, **kwargs):
 		super(TestWorker, self).__init__(*args, **kwargs)
 		self.reset()
 		
-	def fun(self, *args, **kwargs):
+	def fun(self, arg):
 		self.called = True
-		self.args = args 
-		self.kwargs = kwargs
+		self.arg = arg 
 		return True
 		
 	def make_assertion(self):
 		assert self.called
-		assert self.args
-		assert self.kwargs
+		assert self.arg
 		self.reset()
 		
 	def reset(self):
 		self.called = False
-		self.args = None
-		self.kwargs = None
+		self.arg = None
 		
 
 class TestThreads( TestCase ):
@@ -36,10 +34,11 @@ class TestThreads( TestCase ):
 		
 		# test different method types
 		standalone_func = lambda *args, **kwargs: worker.fun(*args, **kwargs)
-		for function in ("fun", TestWorker.fun, worker.fun, standalone_func):
-			worker.call(function, 1, this='that')
+		for function in (TestWorker.fun, worker.fun, standalone_func):
+			worker.inq.put((function, 1))
+			time.sleep(0.01)
 			worker.make_assertion()
 		# END for each function type
 		
-		worker.call('quit')
+		worker.stop_and_join()