[Android] Add sharding for AMP instrumentation tests.

build/android/devil/utils/reraiser_thread.py

 # Copyright 2013 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Thread and ThreadGroup that reraise exceptions on the main thread."""
 # pylint: disable=W0212
 
 import logging
 import sys
 import threading
@@ skipping 195 matching lines @@
 
   Returns:
     The current thread group, otherwise None.
   """
   current_thread = threading.current_thread()
   if isinstance(current_thread, ReraiserThread):
     return current_thread._thread_group  # pylint: disable=no-member
   return None
 
 
-def RunAsync(funcs, watcher=None):
+def RunAsync(funcs, args=None, kwargs=None, watcher=None, names=None):
   """Executes the given functions in parallel and returns their results.
 
   Args:
     funcs: List of functions to perform on their own threads.
+    args: List of list of args to be passed to the corresponding func.
+    kwargs: List of dicts of kwargs to be passed to the corresponding func.
     watcher: Watchdog object providing timeout, by default waits forever.
+    names: List of names for the threads.
 
   Returns:
     A list of return values in the order of the given functions.
   """
-  thread_group = ReraiserThreadGroup(ReraiserThread(f) for f in funcs)
+  args = args or [None]*len(funcs)

[jbudorick, 2015/12/01 04:07:13]

where's the linter when I need it... spaces around operators, plz

+  kwargs = kwargs or [None]*len(funcs)
+  names = names or [None]*len(funcs)
+
+  thread_group = ReraiserThreadGroup(
+      ReraiserThread(f, args=a, kwargs=k, name=n)

[jbudorick, 2015/12/01 04:07:13]

Adding these probably means you're abusing RunAsync somewhere...

+      for (f, a, k, n) in zip(funcs, args, kwargs, names))
   thread_group.StartAll(will_block=True)
   return thread_group.GetAllReturnValues(watcher=watcher)