java Firebase: delay exit до записи заканчивается

Question

У меня есть сервер, написанный на Java, который может получать сигнал отключения, когда он прослушивает, обрабатывает и обновляет данные Firebase. Поскольку потоки Firebase являются потоками демона в Java, я хотел добавить некоторую задержку в основной поток, чтобы разрешить выполнение операций записи.

Моя нынешняя идея - подход с защелкой: используйте некоторый параллельный счетчик для отслеживания ожидающих операций записи и дайте основному потоку выйти, если его нет. Счетчик будет обновлен в обратных вызовах, поэтому мне было интересно:

В клиенте Firebase, когда onComplete() callbacks никогда не вызываются? Существует ли разумная опасность тупика?

Answer 1

взято с this google group discussion. В этом случае используется boolean done (AtomicBoolean для операций с потоками в этом случае) и цикл while.

import com.firebase.client.Firebase; 
import com.firebase.client.FirebaseError; 

import java.util.Date; 
import java.util.concurrent.atomic.AtomicBoolean; 

public class Demo { 

    public static void main(String[] args) { 
     final AtomicBoolean done = new AtomicBoolean(false); 
     Firebase ref = new Firebase("https://testjava.firebaseio-demo.com/"); 
     ref.setValue(new Date().toString(), new Firebase.CompletionListener() { 
      @Override 
      public void onComplete(FirebaseError firebaseError, Firebase firebase) { 
       done.set(true); 
      } 
     }); 
     while (!done.get()); 
    } 
} 

Answer 2

Я думаю, вы должны выключить сервер в 3 этапа:

1. остановка приема больше работы
2. ждать за всю работу, чтобы закончить
3. вопрос к останову для демона пула потоков, когда рабочий счетчик 0.

Используя в своих письменных заданий в finally должен обеспечить onComplete() всегда называется.

try { 
    //write 
} 
finally { 
    callbackObject.onComplete(); 
}