由于Service运行在主线程中，我们就不能在service中直接做耗时的操作，只能通过开启一个子线程来执行耗时任务，当任务执行完毕后，我们要手动通过stopSelf()来停止我们的服务。但往往会有忘记开启线程或忘记停止服务的情况，为了解决这个问题，Android提供了可以简单创建一个异步的，会自动停止的服务——IntentService。
在看IntentService前，我们来学习以下HandlerThread，我们知道，当我们的Android进程建立时，系统会自动调用looper.prepare来初始化一个looper，这个looper存在于主线程，我们在主线程创建一个Hnadler对象，便可以通过发送消息和处理消息的操作，这个handler对象时不能在子线程中使用的。那么如果我们想在子线程中使用handler怎么办，其实我们可以在子线程中调用looper.prepare来初始化一个looper，之后便可以在子线程中使用handler。更简单的方法，就是使用HandlerThread.
HandlerThread实际上就是一个自带looper的Thread。他的用法很简单。
下面时我测试时写的一个demo
public class MainActivity extends AppCompatActivity {
HandlerThread thread;
Handler Mainhandler;//主线程Handler
Handler mHandler;//子线程Handler
TextView textView;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
textView=findViewById(R.id.mytext);
thread=new HandlerThread("myhanlder");
thread.start();
mHandler=new Handler(thread.getLooper()){
@Override
public void handleMessage(Message msg) {
try {
Thread.sleep(1000);
Message message=new Message();
message.what=msg.what;
Mainhandler.sendMessage(message);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
Mainhandler=new Handler(){
@Override
public void handleMessage(Message msg) {
textView.setText(msg.what+"");
}
};
for (int i=0;i<10;i++){
Message message=new Message();
message.what=i;
mHandler.sendMessage(message);
}
}
}
我们新建一个mHandler，由于该handler对象是根据子线程中的looper创建的，因此该handler的handlemessage的方法实际上是在子线程中执行的。在这里我在主线程中通过mhandler的sendmessge的方法发送消息，之后在其handlermessage中我们获取msg后可以执行相应的耗时操作，之后又使用MainHandler切回主线程，刷新界面。
现在来看看HandlerThread的源码：
public class HandlerThread extends Thread {
int mPriority;
int mTid = -1;
Looper mLooper;
public HandlerThread(String name) {
super(name);
mPriority = Process.THREAD_PRIORITY_DEFAULT;
}
protected void onLooperPrepared() {
}
@Override
public void run() {
mTid = Process.myTid();
Looper.prepare();
synchronized (this) {
mLooper = Looper.myLooper();
notifyAll();
}
Process.setThreadPriority(mPriority);
onLooperPrepared();
Looper.loop();
mTid = -1;
}
其run方法内部，初始化了一个looper，注意这里使用synchronized代码块来保证我们的mlooper的初始化。onLooperPrepared默认是个空方法，它执行在looper.loop方法，因此在自定义handlerthread时，我们在这个方法中可以对我们的handler进行创建。
我们创建子线程handler时，使用 mHandler=new Handler(thread.getLooper())；
那我们再来看getlooper（）方法。
public Looper getLooper() {
if (!isAlive()) {
return null;
}
// If the thread has been started, wait until the looper has been created.
synchronized (this) {
while (isAlive() && mLooper == null) {
try {
wait();
} catch (InterruptedException e) {
}
}
}
return mLooper;
}
在这里，重点看 synchronized 中代码，如果线程已经开始运行但是mlooper为空，证明looper对象还没初始化完成，由于我们的handler对象是在UI线程中创建的，而mlooper是在子线程中创建的，因此我们必须保证mlooper对象初始化成功后在返回，当mlooper为空，调用wait来停止当前线程，直到上面run方法执行后，调用notifyall来重新唤起线程，此时looper对象已经初始化完成，可以正确返回。
介绍完HandlerThread，我们再来看IntentService,其实IntentService内部使用到了HandlerThread。直接来看源码：
public abstract class IntentService extends Service {
private volatile Looper mServiceLooper;
private volatile ServiceHandler mServiceHandler;
private String mName;
private boolean mRedelivery;
private final class ServiceHandler extends Handler {
public ServiceHandler(Looper looper) {
super(looper);
}
@Override
public void handleMessage(Message msg) {
onHandleIntent((Intent)msg.obj);
stopSelf(msg.arg1);
}
}
public IntentService(String name) {
super();
mName = name;
}
public void setIntentRedelivery(boolean enabled) {
mRedelivery = enabled;
}
@Override
public void onCreate() {
super.onCreate();
HandlerThread thread = new HandlerThread("IntentService[" + mName + "]");
thread.start();
mServiceLooper = thread.getLooper();
mServiceHandler = new ServiceHandler(mServiceLooper);
}
@Override
public void onStart(Intent intent, int startId) {
Message msg = mServiceHandler.obtainMessage();
msg.arg1 = startId;
msg.obj = intent;
mServiceHandler.sendMessage(msg);
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
onStart(intent, startId);
return mRedelivery ? START_REDELIVER_INTENT : START_NOT_STICKY;
}
@Override
public void onDestroy() {
mServiceLooper.quit();
}
@Override
public IBinder onBind(Intent intent) {
return null;
}
protected abstract void onHandleIntent(Intent intent);
}
在onCreate方法中，我们新建了一个HandlerThread，然后创建一个ServiceHandler，传入HandlerThread中的looper,这样ServiceHandler的handlemessage方法将会运行在子线程中。我们来看ServiceHandler的handlemessage中执行了onHandleIntent的方法，该方法时抽象方法，需要用户去实现，我们的代码逻辑写在此方法中即可。执行完毕后，将调用stopself方法来停止服务。
注意：回调完成后回调用 stopSelf(msg.arg1)，注意这个msg.arg1是个int值，相当于一个请求的唯一标识。每发送一个请求，会生成一个唯一的标识，然后将请求放入队列，当全部执行完成(最后一个请求也就相当于getLastStartId == startId)，或者当前发送的标识是最近发出的那一个（getLastStartId == startId），则会销毁我们的Service.
如果传入的是-1则直接销毁。
那么，当任务完成销毁Service回调onDestory，可以看到在onDestroy中释放了我们的Looper:mServiceLooper.quit()。
好，这就是IntentService的分析。
网友评论