Android: Switch to thread pool executor

chrome/android/javatests/src/org/chromium/chrome/browser/BackgroundSyncLauncherTest.java

Index: chrome/android/javatests/src/org/chromium/chrome/browser/BackgroundSyncLauncherTest.java
diff --git a/chrome/android/javatests/src/org/chromium/chrome/browser/BackgroundSyncLauncherTest.java b/chrome/android/javatests/src/org/chromium/chrome/browser/BackgroundSyncLauncherTest.java
index f26d62d3c819f5fc37b987a914be77e7748e3917..2b1f41f6a3ef6647a350d36d346f74d2544e4e6f 100644
--- a/chrome/android/javatests/src/org/chromium/chrome/browser/BackgroundSyncLauncherTest.java
+++ b/chrome/android/javatests/src/org/chromium/chrome/browser/BackgroundSyncLauncherTest.java
@@ -13,6 +13,7 @@ import org.chromium.base.test.util.AdvancedMockContext;
 import org.chromium.base.test.util.Feature;
 import org.chromium.base.test.util.RetryOnFailure;
 
+import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Semaphore;
 
 /**
@@ -51,7 +52,7 @@ public class BackgroundSyncLauncherTest extends InstrumentationTestCase {
                     }
                 };
 
-        BackgroundSyncLauncher.shouldLaunchBrowserIfStopped(mContext, callback);
+        BackgroundSyncLauncher.shouldLaunchBrowserIfStopped(callback);
         try {
             // Wait on the callback to be called.
             semaphore.acquire();
@@ -61,6 +62,16 @@ public class BackgroundSyncLauncherTest extends InstrumentationTestCase {
         return mShouldLaunchResult;
     }
 
+    private void waitForLaunchBrowserTask() {
+        try {
+            mLauncher.mLaunchBrowserIfStoppedTask.get();
+        } catch (InterruptedException e) {
+            fail("Launch task was interrupted");
+        } catch (ExecutionException e) {
+            fail("Launch task had execution exception");
+        }
+    }
+
     @SmallTest
     @Feature({"BackgroundSync"})
     @RetryOnFailure
@@ -81,9 +92,11 @@ public class BackgroundSyncLauncherTest extends InstrumentationTestCase {
     @RetryOnFailure
     public void testSetLaunchWhenNextOnline() {
         assertFalse(shouldLaunchBrowserIfStoppedSync());
-        mLauncher.launchBrowserIfStopped(mContext, true, 0);
+        mLauncher.launchBrowserIfStopped(true, 0);
+        waitForLaunchBrowserTask();
         assertTrue(shouldLaunchBrowserIfStoppedSync());
-        mLauncher.launchBrowserIfStopped(mContext, false, 0);
+        mLauncher.launchBrowserIfStopped(false, 0);
+        waitForLaunchBrowserTask();
         assertFalse(shouldLaunchBrowserIfStoppedSync());
     }
 
@@ -91,7 +104,8 @@ public class BackgroundSyncLauncherTest extends InstrumentationTestCase {
     @Feature({"BackgroundSync"})
     @RetryOnFailure
     public void testNewLauncherDisablesNextOnline() {
-        mLauncher.launchBrowserIfStopped(mContext, true, 0);
+        mLauncher.launchBrowserIfStopped(true, 0);
+        waitForLaunchBrowserTask();
         assertTrue(shouldLaunchBrowserIfStoppedSync());
 
         // Simulate restarting the browser by deleting the launcher and creating a new one.