AsyncTask如何在没有deadLock的情况下等待另一个

Question

我试图实现2个异步任务，其中一个应该等待另一个完成。

我做一个测试案例吧，看起来像这样：

public class MainActivity extends Activity{ 

    public static boolean SYNCING = false; 
    public static Object LOCK = new Object(); 

    public static void setSync(){ 
     Log.i(TAG, "setting Sync=true"); 
     synchronized (LOCK) { 
      SYNCING = true; 
     } 
    } 

    public static void waitForSync(){ 
     Log.i(TAG, "waiting for Sync"); 
     synchronized (LOCK) { 
      try{ 
       while (SYNCING){ 
        LOCK.wait(); 
       } 
      } catch (InterruptedException ignore){} 
     } 
    } 

    public static void setSyncFinish(){ 
     Log.i(TAG, "setSyncFinish to notify all"); 
     synchronized (LOCK) { 
      SYNCING = false; 
      LOCK.notifyAll(); 
     } 
    } 

    public class WaitingOnLoaderTask extends AsyncTask<Void, Void, Void>{ 

     @Override 
     protected Void doInBackground(Void... params) { 
      Log.i(TAG, "doInBackground of WaitingForLoaderTask"); 

      try { 
       Thread.sleep(500); 
      } catch (InterruptedException e) { 

      } 

      waitForSync(); 
      Log.i(TAG, "finishedWaiting!"); 
      return null; 
     } 

    } 

    public class LoaderTask extends AsyncTask<Void, Void, Void>{ 

     long mRuntime; 
     int mTimes; 

     public LoaderTask(long runtime, int times){ 
      mRuntime = runtime; 
      mTimes = times; 
     } 

     @Override 
     protected Void doInBackground(Void... params) { 
      while(mTimes >= 0){ 
       Log.i(TAG, "sleeping for " + mTimes + " times for " + mRuntime + " milliseconds"); 
       mTimes--; 
       try { 
        Thread.sleep(mRuntime); 
       } catch (InterruptedException e) { 
        Log.e("MainActivity", "Interrupted", e); 
       } 
      } 

      setSyncFinish(); 

      return null; 
     } 

    } 
} 

但我不能让WaitingOnLoaderTask正确地等待。如果我的onCreate运行此

new WaitingOnLoaderTask().execute((Void[])null); 
new LoaderTask(1000, 5).execute((Void[])null); 

我得到这样一个logOutput（死锁发生）：

03-08 18:17:23.309: I/myUniqueLogTag(4432): setting Sync=true 
03-08 18:17:23.317: I/myUniqueLogTag(4432): doInBackground of WaitingForLoaderTask 
03-08 18:17:23.817: I/myUniqueLogTag(4432): waiting for Sync 

和

new LoaderTask(1000, 5).execute((Void[])null); 
new WaitingOnLoaderTask().execute((Void[])null); 

我得到一个日志是这样的：

03-08 18:18:53.082: I/myUniqueLogTag(4621): sleeping for 5 times for 1000 milliseconds 
03-08 18:18:54.082: I/myUniqueLogTag(4621): sleeping for 4 times for 1000 milliseconds 
03-08 18:18:55.090: I/myUniqueLogTag(4621): sleeping for 3 times for 1000 milliseconds 
03-08 18:18:56.082: I/myUniqueLogTag(4621): sleeping for 2 times for 1000 milliseconds 
03-08 18:18:57.090: I/myUniqueLogTag(4621): sleeping for 1 times for 1000 milliseconds 
03-08 18:18:58.106: I/myUniqueLogTag(4621): sleeping for 0 times for 1000 milliseconds 
03-08 18:18:59.113: I/myUniqueLogTag(4621): doInBackground of WaitingForLoaderTask 
03-08 18:18:59.113: I/myUniqueLogTag(4621): setSyncFinish to notify all 
03-08 18:18:59.621: I/myUniqueLogTag(4621): waiting for Sync 
03-08 18:18:59.621: I/myUniqueLogTag(4621): finishedWaiting! 

所以我想一个是防止o运行。他们是否实际上在同一个线程中计算了它们的doInBackground，并且LOCK.wait()阻止此线程进一步执行？

有没有办法解决它（并保持与Android 2.2兼容）？

注意： 第二次基本上是我想要的，但在其他任务实现中，我不能确定WaitingOnLoaderTask仅在另一个完成时才会执行。

Answer 1

最好的办法是使用Geobits建议。

可以使用onPostExecute（）函数来调用下一个异步任务，因此将执行它：

class WaitingOnLoaderTask extends AsyncTask<Void,Void,Void> 
{ 
    protected void onPreExecute(Void) 
    { 
     super.onPreExecute(); 
    } 

    protected void doInBackground(Void... params) 
    { 
     //Commands for first AsyncTask 
    } 

    protected void onPostExecute(Void) 
    { 
     //Call AsyncTask 2 
    } 
} 

这样，它会等到任务1完成。

Answer 2

您的代码在Android 3.2及更低版本上按预期工作。在更高版本的Android版本AsyncTasks不执行并行尝试这让它在Android 4+工作：

LoaderTask loaderTask = new LoaderTask(1000, 5); 
WaitingOnLoaderTask waitingTask = new WaitingOnLoaderTask(); 
if (Build.VERSION.SDK_INT >= 14) { 
    loaderTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); 
    waitingTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); 
} else { 
    loaderTask.execute(); 
    waitingTask.execute(); 
} 

注意：您应该标记您AsyncTasks为static，以避免对配置更改（例如旋转）漏水活动。