Firebase realtimedbでの非同期処理を完了させるまで待機させたい。

Question

下記の処理にて、Firebaseのrealtimedbで、一旦メインスレッドを　wait(latch.await())して、
onDataChange非同期メソッドにてデータ取得が完了したらメインスレッドの次の処理に進むようにしたいのですが、await()メソッドを記述するとそもそも、onDataChangeメソッドに入れずに、次の処理に進めません。
原因がわからないため、解決策を教えていただきたいです。
よろしくお願いします。

public class TalkActivity extends BaseActivity implements View.OnClickListener{
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        FirebaseDatabase database = FirebaseDatabase.getInstance();

        DatabaseReference myRef = database.getReference("messages/" + roomId + "/");
        final DataSnapshotWrapper snapshotWrapper = new DataSnapshotWrapper();
        
        //非同期処理のカウント変数(初期値が1)
        final CountDownLatch latch = new CountDownLatch(1);

        //DBを読み出し
        myRef.addValueEventListener(new ValueEventListener() {
            @Override
            public void onDataChange(@NonNull DataSnapshot dataSnapshot) {
                DatabaseReference subRef;
                snapshotWrapper.snapshot = dataSnapshot;
　　　　　　　　　 
                //データ処理が完了したのでカウントを一つ減らす。
                latch.countDown();
                messageDataBeanList.clear();
                mainDataSnapShot = dataSnapshot;
            }

            @Override
            public void onCancelled(@NonNull DatabaseError error) {
                // Failed to read value
                Toast.makeText(context, "DB読み込みに失敗しました。", Toast.LENGTH_LONG).show();
            }
        });

        try {
            System.out.println("Prelatch");
　　　　　　
　　　　　    //カウントダウン変数(latch)が0になるまで(上記の非同期処理が完了したら)待機
            latch.await();
            System.out.println("Returning from latch");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

Answer 1

latch.await() をメインスレッド上で呼び出すとメインスレッドを停止させることになりますから、ANRが発生します。別スレッドを用意してその中でawaitするようにするか、CountDownLatchを使わず素直にコールバックで処理するのが良いと思います。