Дождитесь завершения целого набора AsyncTask

Question

Я распараллеливаю свою операцию, разбивая ее на точное количество доступных сердечников, а затем, запустив такое же количество AsyncTask, выполнив ту же операцию, но на разных частях данных.

Я использую executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, ...), чтобы распараллелить их выполнение.

Я хотел бы знать, когда каждая нить заканчивает работу, чтобы объединить все результаты и выполнить дальнейшие операции.

Как я могу это сделать?

Answer 1

Вы также можете просто уменьшаете счетчик в общем объекте как часть onPostExecute. Поскольку onPostExecute работает в одном потоке (основной поток), вам не придется беспокоиться о синхронизации.

UPDATE 1

Общий объект может выглядеть примерно так:

public class WorkCounter { 
    private int runningTasks; 
    private final Context ctx; 

    public WorkCounter(int numberOfTasks, Context ctx) { 
     this.runningTasks = numberOfTasks; 
     this.ctx = ctx; 
    } 
    // Only call this in onPostExecute! (or add synchronized to method declaration) 
    public void taskFinished() { 
     if (--runningTasks == 0) { 
      LocalBroadcastManager mgr = LocalBroadcastManager.getInstance(this.ctx); 
      mgr.sendBroadcast(new Intent("all_tasks_have_finished")); 
     } 
    } 
} 

UPDATE 2

Согласно комментариям к этому ответу, OP ищет решение в котором он может избежать строительства нового класса. Это может быть сделано путем разделяя AtomicInteger среди порождены AsyncTask с:

// TODO Update type params according to your needs. 
public class MyAsyncTask extends AsyncTask<Void,Void,Void> { 
    // This instance should be created before creating your async tasks. 
    // Its start count should be equal to the number of async tasks that you will spawn. 
    // It is important that the same AtomicInteger is supplied to all the spawned async tasks such that they share the same work counter. 
    private final AtomicInteger workCounter; 

    public MyAsyncTask(AtomicInteger workCounter) { 
     this.workCounter = workCounter; 
    } 

    // TODO implement doInBackground 

    @Override 
    public void onPostExecute(Void result) { 
     // Job is done, decrement the work counter. 
     int tasksLeft = this.workCounter.decrementAndGet(); 
     // If the count has reached zero, all async tasks have finished. 
     if (tasksLeft == 0) { 
      // Make activity aware by sending a broadcast. 
      LocalBroadcastManager mgr = LocalBroadcastManager.getInstance(this.ctx); 
      mgr.sendBroadcast(new Intent("all_tasks_have_finished"));  
     } 
    } 
} 

Answer 2

Вы должны использовать CountDownLatch. Здесь документация с примерами: java.util.concurrent.CountDownLatch

В основном вы даете ссылку на CountDownLatch для ваших потоков, и каждый из них будет уменьшать его, когда закончил:

countDownLatch.countDown(); 

Основной поток будет ждать окончания всех с использованием:

countDownLatch.await(); 

Answer 3

Другим вариантом может быть сохранение всех ваших новых потоков в массиве.

Затем вы можете выполнить итерацию по массиву и подождать с потоком [i] .join для завершения потока.

см присоединиться() http://developer.android.com/reference/java/lang/Thread.html#Thread(java.lang.Runnable)

Когда итерация закончена все ваши нити сделаны и вы можете работать на