GothenburgBitFactory/taskwarrior
1
0
Fork 0
mirror of https://github.com/GothenburgBitFactory/taskwarrior.git synced 2025-07-07 20:06:36 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Test: Show total time on serial and parallel tests

Browse source 
Visible only when using run_all -l (or above)
This commit is contained in:
Renato Alves 2015-07-13 02:13:43 +01:00
parent e48fae387e
commit 157f191546
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
test/run_all
View file

@ -19,7 +19,8 @@ os.environ["TASKD_USE_PATH"] = "1"
TIMEOUT = .2
def run_test(testqueue, outqueue):
def run_test(testqueue, outqueue, threadname):
start = time.time()
while True:
try:
test = testqueue.get(block=True, timeout=TIMEOUT)
@ -43,6 +44,9 @@ def run_test(testqueue, outqueue):
testqueue.task_done()
log.warning("Finished %s thread after %s seconds",
threadname, round(time.time() - start, 3))
class TestRunner(object):
def __init__(self):
@ -77,11 +81,11 @@ class TestRunner(object):
def _prepare_threads(self):
# Serial thread
self.threads.append(
Thread(target=run_test, args=(self._serialq, self._outputq))
Thread(target=run_test, args=(self._serialq, self._outputq, "Serial"))
)
# Parallel threads
self.threads.extend([
Thread(target=run_test, args=(self._parallelq, self._outputq))
Thread(target=run_test, args=(self._parallelq, self._outputq, "Parallel"))
for i in range(cpu_count())
])
log.info("Spawned %s threads to run tests", len(self.threads))