我有一个MainActivity
它将向远程AutoCompleteService
服务发出 IPC 调用。
在执行AutoCompleteService
的 IPC 功能期间,服务将向 发出另一个 IPC 回调MainActivity
。
MainActivity.java
// Receive IPC call from AutoCompleteService.
private StockInfoObserver.Stub stockInfoObserver = new StockInfoObserver.Stub() {
@Override
public void update(StockInfo stockInfo) throws RemoteException {
// TODO Auto-generated method stub
Log.i(TAG, android.os.Process.myPid() + " : MainActivity receive ipc call : " + Thread.currentThread().getId());
}
};
...
...
...
// Issue IPC call to AutoCompleteService.
button.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View arg0) {
// Test on API.
try {
Log.i(TAG, android.os.Process.myPid() + " : MainActivity start issue IPC call to remote service : " + Thread.currentThread().getId());
// autoCompleteApi.handle will issue IPC call to remote service.
autoCompleteApi.handle("abc");
Log.i(TAG, android.os.Process.myPid() + " : MainActivity end issue IPC call to remote service : " + Thread.currentThread().getId());
} catch (RemoteException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
自动完成服务.java
private AutoCompleteApi.Stub autoCompleteApi = new AutoCompleteApi.Stub() {
private List<StockInfoObserver> stockInfoObservers = new ArrayList<StockInfoObserver>();
@Override
public void handle(String string) {
Log.i(TAG, android.os.Process.myPid() + " : AutoCompleteService start receive ipc call : " + Thread.currentThread().getId());
try {
for (StockInfoObserver stockInfoObserver : stockInfoObservers) {
Log.i(TAG, android.os.Process.myPid() + " : AutoCompleteService start IPC call to MainActivity : " + Thread.currentThread().getId());
// stockInfoObserver.update will issue IPC call back to MainActivity
stockInfoObserver.update(null);
Log.i(TAG, android.os.Process.myPid() + " : AutoCompleteService end IPC call to MainActivity : " + Thread.currentThread().getId());
}
} catch (RemoteException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Log.i(TAG, android.os.Process.myPid() + " : AutoCompleteService end receive ipc call : " + Thread.currentThread().getId());
}
@Override
public void attachStockInfoObserver(StockInfoObserver stockInfoObserver)
throws RemoteException {
if (stockInfoObservers.contains(stockInfoObserver) == false) {
stockInfoObservers.add(stockInfoObserver);
}
}
};
我最初的预期是,会发生死锁。这是由于我的观察。发出 IPC 调用时,发出者只会在 IPC 接收者完成其 IPC 函数执行后从 IPC 调用返回。
MainActivity
AutoCompleteService
通过发出 IPC 调用autoCompleteApi.handle
。MainActivity
现在将等到AutoCompleteService
完成执行。AutoCompleteService
MainActivity
通过发出 IPC 调用stockInfoObserver.update
。AutoCompleteService
现在将等到MainActivity
完成执行。- 但是,
MainActivity
的线程仍在等待,没有线程将执行update
功能。 - 两个进程一直在等待对方。
但是,上述情况不会发生。这是我得到的日志。一切都完美无瑕。
// Log in MainActivity TAG
3930 : MainActivity start issue IPC call to remote service : 1
3930 : MainActivity receive ipc call : 1
3930 : MainActivity end issue IPC call to remote service : 1
// Log in AutoCompleteService TAG
3961 : AutoCompleteService start receive ipc call : 494
3961 : AutoCompleteService start IPC call to MainActivity : 494
3961 : AutoCompleteService end IPC call to MainActivity : 494
3961 : AutoCompleteService end receive ipc call : 494
但我真的不明白。如果 MainActivity 线程(Id 为 1)没有从函数调用(autoCompleteApi.handle
)返回,它如何“跳转”到执行另一个函数(update(StockInfo stockInfo)
)?
我期待MainActivity 接收由不同线程打印的 ipc 调用。不是 ID 为 1 的线程。如果不是,应该会发生死锁。
如果您有兴趣尝试,请在此处下载完整的源代码:https ://www.dropbox.com/s/8hd7v5acjd213l1/jstock-android2.zip