Add ThreadPool.abort() to stop processing early.

tools/run_swarm_tests_on_swarm.py

 #!/usr/bin/env python
 # Copyright (c) 2012 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.
 
 """Runs the whole set unit tests on swarm."""
 
 import datetime
 import glob
 import getpass
@@ skipping 57 matching lines @@
             'archive',
             '--isolate', os.path.join(BASE_DIR, 'run_a_test.isolate'),
             '--isolated', isolated,
             '--outdir', self.isolate_server,
             '--variable', 'TEST_EXECUTABLE', test,
             '--variable', 'OS', OSES[platform],
           ])
       step_name = '%s/%s (%3.2fs)' % (platform, test_name, duration)
       if returncode:
         self.progress.update_item(
-            'Failed to archive %s\n%s' % (step_name, stdout), index=True)
+            'Failed to archive %s\n%s' % (step_name, stdout), index=1)
       else:
         hash_value = hashlib.sha1(open(isolated, 'rb').read()).hexdigest()
         logging.info('%s: %s', step_name, hash_value)
-        self.progress.update_item('Archived %s' % step_name, index=True)
+        self.progress.update_item('Archived %s' % step_name, index=1)
         self.add_task(0, self.trigger, test, platform, hash_value)
     finally:
       try:
         os.remove(isolated)
       except OSError:
         logging.debug('%s was already deleted', isolated)
     return None
 
   def trigger(self, test, platform, hash_value):
     test_name = os.path.basename(test)
@@ skipping 11 matching lines @@
           # Test name.
           'swarm_client_tests_%s_%s' % (platform, test_name),
           # Number of shards.
           '1',
           # test filter.
           '*',
         ])
     step_name = '%s/%s (%3.2fs)' % (platform, test_name, duration)
     if returncode:
       self.progress.update_item(
-          'Failed to trigger %s\n%s' % (step_name, stdout), index=True)
+          'Failed to trigger %s\n%s' % (step_name, stdout), index=1)
     else:
-      self.progress.update_item('Triggered %s' % step_name, index=True)
+      self.progress.update_item('Triggered %s' % step_name, index=1)
       self.add_task(0, self.get_result, test, platform)
     return None
 
   def get_result(self, test, platform):
     test_name = os.path.basename(test)
     name = '%s_%s' % (platform, test_name)
     returncode, stdout, duration = self._call(
         [
           'swarming.py',
           'collect',
           '--swarming', self.swarm_server,
           self.prefix + 'swarm_client_tests_' + name,
         ])
     step_name = '%s/%s (%3.2fs)' % (platform, test_name, duration)
     # Only print the output for failures, successes are unexciting.
     if returncode:
       self.progress.update_item(
-          'Failed %s:\n%s' % (step_name, stdout), index=True)
+          'Failed %s:\n%s' % (step_name, stdout), index=1)
       return (test_name, platform, stdout)
-    self.progress.update_item('Passed %s' % step_name, index=True)
+    self.progress.update_item('Passed %s' % step_name, index=1)
     return None
 
 
 def run_swarm_tests_on_swarm(oses, tests, logs, isolate_server, swarm_server):
   runs = len(tests) * len(oses)
   total = 3 * runs
   progress = threading_utils.Progress(total)
   progress.use_cr_only = False
   tempdir = tempfile.mkdtemp(prefix='swarm_client_tests')
   try:
@@ skipping 92 matching lines @@
   return run_swarm_tests_on_swarm(
       oses,
       tests,
       options.logs,
       options.isolate_server,
       options.swarming)
 
 
 if __name__ == '__main__':
   sys.exit(main())