如何确保只有一个AsyncTask在后台运行

Question

我有一个类，DownloadAndSave，从AsyncTask延伸。在其doInBackground方法中，它从http连接中检索数据并使用OrmLite保存数据，但也清除数据库中的旧条目。所以，这样的事情：

doInBackground() 
{ 
    clearDb(); 
    dataList = fetchDataFromHttp(); 
    saveToDb(dataList); 
} 

我经常得到一个DB例外：

试图重新打开一个已关闭的对象：SQLiteDatabase

在clearDb

（）和saveToDb（）函数。

而这是不好的，因为来自前一个DownloadAndSave调用的旧数据与来自DownloadAndSave的新数据混合在一起。

在我看来，我需要确保当我启动一个线程时，DownloadAndSave类中的所有其他线程都已完成，换句话说，我需要一次运行最多一个DownloadAndSave的一个实例。所以问题是：如何确保在任何时间点只有一个DownloadAndSave实例会运行？

Answer 1

选项1。在一个单独的类用于同步对类对象

clearDb(); 
dataList = fetchDataFromHttp(); 
saveToDb(dataList); 

：

public class WorkerClass { 
    private WorkerListener workerListener; 

    public static interface WorkerListener { 
     public void publishWorkProgress(String data); 
    } 

    public WorkerClass(WorkerListener workerListener) { 
     this.workerListener = workerListener; 
    } 

    public void performWork() { 
     synchronized (WorkerClass.class) { 
      clearDb(); 
      publish("Cleared DB"); 
      dataList = fetchDataFromHttp(); 
      publish("Got http data"); 
      saveToDb(dataList); 
      publish("There! saved!"); 
     } 
    } 

    private void publish(String message) { 
     if(workerListener != null) { 
      workerListener.publishWorkProgress(message); 
     } 
    } 

} 

虽然从活动：

public class SampleActivity extends Activity { 

    public void doTheThing() { 
     new MyAsyncTask().execute(); 
    } 

    private static class MyAsyncTask extends AsyncTask<Void, String, Void> implements WorkerListener { 
     @Override 
     protected Void doInBackground(Void... params) { 
      new WorkerClass(this).performWork(); 
      return null; 
     } 

     @Override 
     public void publishWorkProgress(String data) { 
      publishProgress(data); 
     } 
    } 
} 

选项2：移动上述代码的移动上述IntentService：

public class WorkerIntentService extends IntentService { 
    public WorkerIntentService() { 
     super(null); 
    } 

    @Override 
    protected void onHandleIntent(Intent intent) { 
     clearDb(); 
     dataList = fetchDataFromHttp(); 
     saveToDb(dataList); 
    } 
} 

使用IntentService可确保任务按顺序执行。

Answer 2

如果你在doInBackground中使用db操作，你应该锁定db为一个线程。

public void insertToDb(){ 
SQliteDatabase db; 
... 
db.beginTransaction(); 
...//operation 
db.yieldIfContendedSafely(); 
db.setTransactionSuccessful(); 
db.endTransaction(); 
} 

Answer 3

我相信你面临的问题是你从一个活动开始AsyncTask。您的活动正在扩展ORMLiteBaseActivity，它打开帮助器（以及该数据库）onCreate并关闭它onDestroy。当您退出活动并且后台任务仍未完成时，在尝试写入数据库时​​，最终会收到一个关闭的数据库。

ORMLite在内部处理同步，我从来不需要使用同步块。我在所有需要数据库的项目中都使用它。

对于其他答案，错误是一个封闭的数据库，而不是并发写操作，所以同步没有意义。

Answer 4

由于Android API的API版本11（HONEYCOMB），在给定的Executor上，AsyncTask可以是executed。您可以使用默认的SerialExecutor按顺序执行任务。