ループ内のコールバック：すべて終了したときを知る方法？

Question

ループでは、コールバックを持つメソッドを複数回呼び出す必要があります。すべてが終わったとき、どうすればわかるのですか？

@Override 
public void onObjectsMustBeParsed(String parsableObjects) { 
    String[] parsedObjects = parsableObjects.split(","); 

    for (String parsedObject : parsedObjects){ 

     loadObject(parsedObject, new LoadObjectCallback() { 
      @Override 
      public void onObjectLoaded(Object object) { 
       //Object Loaded 
       saveObject(object, new SaveObjectCallback() { 
        @Override 
        public void onObjectSaved() { 
         // Object saved 
        } 

        @Override 
        public void onError() { 
         // Object not saved 

        } 
       }); 
      } 

      @Override 
      public void onError(Throwable throwable) { 
       // Object not Loaded 

      } 
     }); 
    } 
} 


// => do something when all processing of parsed-objects are finished 
     // do something if all is ok 
     // do other thing if partially ok 

注：データを操作するために、私はローカルとリモートのデータソースを持つリポジトリを使用します。このコードはリポジトリの一部です。

Answer 1

は、実行中のタスクの量を示す整数揮発性を追加します。タスクを開始すると増加します。 onObjectLoadedまたはonObjectSavedの値の減少。その後、すべてのデクリメント後に、タスクカウンタがnulであるかどうかをチェックします。

Answer 2

同様のコメントへのアプローチが、代わりのAtomicIntegerを使用して：

AtomicInteger countDownLatch = null; 

    @Override 
    public void onObjectsMustBeParsed(String parsableObjects) { 
     String[] parsedObjects = parsableObjects.split(","); 

     countDownLatch = new AtomicInteger(parsedObjects.length); 
     for (String parsedObject : parsedObjects){ 

     loadObject(parsedObject, new LoadObjectCallback() { 
      @Override 
      public void onObjectLoaded(Object object) { 
       //Object Loaded 
       saveObject(object, new SaveObjectCallback() { 
        @Override 
        public void onObjectSaved() { 
        // Object saved 
        int value = countDownLatch.decrementAndGet(); 
        if (value == 0) { 
         // we are done 
        } 

        } 

        @Override 
        public void onError() { 
        // Object not saved 
        int value = countDownLatch.decrementAndGet(); 
        if (value == 0) { 
         // we are done 
        } 
        } 
       }); 
      } 

      @Override 
      public void onError(Throwable throwable) { 
       // Object not Loaded 

      } 
     }); 
     } 
    }