build/android/devil/utils/reraiser_thread.py - Issue 1415533007: [Android] Add sharding for AMP instrumentation tests.

Keyboard Shortcuts

	File
u :	up to issue
j / k :	jump to file after / before current file
J / K :	jump to next file with a comment after / before current file
	Side-by-side diff
i :	toggle intra-line diffs
e :	expand all comments
c :	collapse all comments
s :	toggle showing all comments
n / p :	next / previous diff chunk or comment
N / P :	next / previous comment
<Up> / <Down> :	next / previous line

	Issue
u :	up to list of issues
j / k :	jump to patch after / before current patch
o / <Enter> :	open current patch in side-by-side view
i :	open current patch in unified diff view

	Issue List
j / k :	jump to issue after / before current issue
o / <Enter> :	open current issue

Unified Diff: build/android/devil/utils/reraiser_thread.py

Issue 1415533007: [Android] Add sharding for AMP instrumentation tests. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master

Patch Set: Addressed rnephew's comments. Created 5 years, 1 month ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View side-by-side diff with in-line comments

Download patch

Index: build/android/devil/utils/reraiser_thread.py

diff --git a/build/android/devil/utils/reraiser_thread.py b/build/android/devil/utils/reraiser_thread.py

index e108fc754fbe9befd62c25dfe1e68f97ef071161..dbaa1ea0d7fe72f25e0c3f3a5b669f870f553669 100644

--- a/build/android/devil/utils/reraiser_thread.py

+++ b/build/android/devil/utils/reraiser_thread.py

@@ -226,3 +226,13 @@ def RunAsync(funcs, watcher=None):

thread_group = ReraiserThreadGroup(ReraiserThread(f) for f in funcs)

thread_group.StartAll(will_block=True)

return thread_group.GetAllReturnValues(watcher=watcher)

+def RunThreadsSync(threads):

jbudorick 2015/11/17 18:04:46 There's no reason why both this and RunAsync shoul

mikecase (-- gone --) 2015/11/19 01:35:37 Added support to RunAsync to pass args and kwargs

+ """Runs the given threads in parallel and blocks until all threads finish.

+ Args:

+ threads: List of reraiser_thread objects.

+ """

+ workers = ReraiserThreadGroup(threads)

+ workers.StartAll()

+ workers.JoinAll()

« no previous file with comments | « build/android/devil/utils/parallelizer.py ('k') | build/android/devil/utils/tempdir.py » ('j') | build/android/devil/utils/tempdir.py » ('J')