diff options
Diffstat (limited to 'test/git/async/test_performance.py')
-rw-r--r-- | test/git/async/test_performance.py | 51 |
1 files changed, 0 insertions, 51 deletions
diff --git a/test/git/async/test_performance.py b/test/git/async/test_performance.py deleted file mode 100644 index 703c8593..00000000 --- a/test/git/async/test_performance.py +++ /dev/null @@ -1,51 +0,0 @@ -"""Channel testing""" -from test.testlib import * -from task import * - -from git.async.pool import * -from git.async.thread import terminate_threads -from git.async.util import cpu_count - -import time -import sys - - - -class TestThreadPoolPerformance(TestBase): - - max_threads = cpu_count() - - def test_base(self): - # create a dependency network, and see how the performance changes - # when adjusting the amount of threads - pool = ThreadPool(0) - ni = 1000 # number of items to process - print self.max_threads - for num_threads in range(self.max_threads*2 + 1): - pool.set_size(num_threads) - for num_transformers in (1, 5, 10): - for read_mode in range(2): - ts, rcs = add_task_chain(pool, ni, count=num_transformers, - feedercls=IteratorThreadTask, - transformercls=TestPerformanceThreadTask, - include_verifier=False) - - mode_info = "read(0)" - if read_mode == 1: - mode_info = "read(1) * %i" % ni - # END mode info - fmt = "Threadcount=%%i: Produced %%i items using %s in %%i transformations in %%f s (%%f items / s)" % mode_info - reader = rcs[-1] - st = time.time() - if read_mode == 1: - for i in xrange(ni): - assert len(reader.read(1)) == 1 - # END for each item to read - else: - assert len(reader.read(0)) == ni - # END handle read mode - elapsed = time.time() - st - print >> sys.stderr, fmt % (num_threads, ni, num_transformers, elapsed, ni / elapsed) - # END for each read-mode - # END for each amount of processors - # END for each thread count |