service的异步创建
做过Android开发的基本都清楚,当进行bindService调用的时候,需要传递一个ServiceConnection,当service创建完毕之后,会回调ServiceConnection的方法来通知调用方,也就是说bindService是异步的。
根本原因在于service的onCreate/onStartCommand/onStart
生命周期相关的方法总是在 主线程
上执行的,如果bindService在主线程上阻塞的话,这个时候,service就无法执行上述生命周期相关的方法,完成初始化工作。既然不能阻塞,只好通过ServiceConnection来回调通知了。
进一步而言,bindService之后,需要立刻返回,从而执行ActivityThread中的消息循环,从而处理service创建等消息。详见: http://androidxref.com/5.0.0_r2/xref/frameworks/base/core/java/android/app/ActivityThread.java#1360
用官方文档来说,就是service是运行在主线程上的,也因此,可能会引发ANR,所以耗时的工作应该在service创建工作者线程来完成。
https://developer.android.com/guide/components/services.html?hl=zh-cn
注意:服务在其托管进程的主线程中运行,它既不创建自己的线程,也不在单独的进程中运行(除非另行指定)。 这意味着,如果服务将执行任何 CPU 密集型工作或阻止性操作(例如 MP3 播放或联网),则应在服务内创建新线程来完成这项工作。通过使用单独的线程,可以降低发生“应用无响应”(ANR) 错误的风险,而应用的主线程仍可继续专注于运行用户与 Activity 之间的交互。
这样做,其实有很多优势,毕竟,主线程并非会一直运行,例如Activity后台化等情况,如果service在独立的线程中执行,显然会消耗一定的资源。
不过这里说的是service和调用方是同一进程的情况,如果不同的进程,理论是不是可以实现为同步呢?显然不是的,如果bindService阻塞主线程,导致5秒内没响应输入事件,这个时候会引发ANR,而service执行超时是20秒,因此为了规避这种问题,bindService采用异步设计。
工作者线程阻塞方式bindService
很多时候,异步方式使用起来不是那么方便,如果是在工作者线程,可以使用同步方式来bindService,下面的代码来自于: http://androidxref.com/5.0.0_r2/xref/frameworks/base/keystore/java/android/security/KeyChain.java
public static KeyChainConnection bindAsUser(Context context, UserHandle user)
throws InterruptedException {
if (context == null) {
throw new NullPointerException("context == null");
}
// 如果是非工作者线程,则抛出异常
ensureNotOnMainThread(context);
// 声明一个阻塞队列,bindService之后,等待这个队列有数据入队
final BlockingQueue<IKeyChainService> q = new LinkedBlockingQueue<IKeyChainService>(1);
ServiceConnection keyChainServiceConnection = new ServiceConnection() {
volatile boolean mConnectedAtLeastOnce = false;
@Override public void onServiceConnected(ComponentName name, IBinder service) {
if (!mConnectedAtLeastOnce) {
mConnectedAtLeastOnce = true;
try {
q.put(IKeyChainService.Stub.asInterface(service));
} catch (InterruptedException e) {
// will never happen, since the queue starts with one available slot
}
}
}
@Override public void onServiceDisconnected(ComponentName name) {}
};
Intent intent = new Intent(IKeyChainService.class.getName());
ComponentName comp = intent.resolveSystemService(context.getPackageManager(), 0);
intent.setComponent(comp);
boolean isBound = context.bindServiceAsUser(intent,
keyChainServiceConnection,
Context.BIND_AUTO_CREATE,
user);
if (!isBound) {
throw new AssertionError("could not bind to KeyChainService");
}
return new KeyChainConnection(context, keyChainServiceConnection, q.take());
}
private static void ensureNotOnMainThread(Context context) {
Looper looper = Looper.myLooper();
if (looper != null && looper == context.getMainLooper()) {
throw new IllegalStateException(
"calling this from your main thread can lead to deadlock");
}
}
网友评论