Android：調用遠程Messenger服務的同步方法

Question

我想編寫一個連接到遠程服務的模塊。

該模塊可供開發人員在其應用程序中用於連接特定（藍牙）硬件。然後它應該連接到一個單獨的遠程服務，可以單獨在市場上更新。

由於遠程服務只允許同時使用它的所有應用程序只有一個線程（通過藍牙只有一個連接），所以我選擇了使用AIDL的信使方法。

我的問題是現在我想在我的公共API中提供一個同步方法，但服務返回一個處理程序 - 並且據我所知，處理程序將全部等待當前任務完成...那麼有什麼方法可以在不同的線程中得到答案？

同步方法的代碼，因爲我想它是：預先

responseDataSync = new Sync<ResponseData>(); 

    // Send message 
    Message msg = Message.obtain(null, Constants.DATA, 1, 0); 

    send(msg); 

    try { 
     ResponseData responseData = responseDataSync.get(); 

     // with responseDataSync using a countdown latch to synchronize... 
// but it never fires thanks to the handler. 
//etc... 

感謝。我希望我的問題有點可以理解......;）

/編輯： 我想要一些從服務器返回數據的方法。像

public ResponseData returnResponse(Data dataToSend) 

，但我不能等待該服務的回報，因爲那時我被困在線程塊什麼在處理程序從返回...

Answer 1

一個Handler與一個消息隊列關聯。如果你從任何一個線程發送一個Message，它將會在那裏排隊。

接收所有消息的線程將從隊列中獲取適當的消息並逐個處理它。

對你有意義，如果你有一個處理程序，並且你通過你的處理程序運行所有的消息，你不需要同步，因爲一切都在一個線程中處理。

編輯：創建一個後臺線程處理消息的處理程序：

HandlerThread ht = new HandlerThread("threadName"); 
ht.start(); 
Looper looper = ht.getLooper(); 
Handler.Callback callback = new Handler.Callback() { 

    @Override 
    public boolean handleMessage(Message msg) { 
     // handled messages are handled in background thread 
     return true; 
    } 
}; 
Handler handler = new Handler(looper, callback); 

handler.sendEmptyMessage(1337); 

EDIT2：等待消息可能像這樣工作

// available for all threads somehow 
final Object waitOnMe = new Object(); 

HandlerThread ht = new HandlerThread("threadName"); 
ht.start(); 
Looper looper = ht.getLooper(); 
Handler.Callback callback = new Handler.Callback() { 

    @Override 
    public boolean handleMessage(Message msg) { 
     // handled messages are handled in background thread 
     // then notify about finished message. 
     synchronized (waitOnMe) { 
      waitOnMe.notifyAll(); 
     } 
     return true; 
    } 
}; 
Handler handler = new Handler(looper, callback); 

// in a different Thread: 
synchronized (waitOnMe) { 
    handler.sendEmptyMessage(1337); 
    try { 
     waitOnMe.wait(); 
    } catch (InterruptedException e) { 
     // we should have gotten our answer now. 
    } 
} 

您有分發（遠程）服務