您的位置:首页 > 移动开发 > Android开发

Android知识巩固--IntentService详解(消息机制的优秀实践)

2018-02-23 15:04 477 查看

为什么需要IntentService?

我们都知道Service是负责在后台处理比较耗时的操作的。但实际上Service也是运行在主线程中的。在我们需要在Service中开启子线程来执行我们的耗时操作。

一个使用Service的案例:

public class MyService extends Service {
@Nullable
@Override
public IBinder onBind(Intent intent) {
return null;
}

@Override
public void onCreate() {
super.onCreate();
Log.w("TAG", "Service Thread:"+Thread.currentThread().getId() + ":" + Thread.currentThread().getName());
new Thread(new Runnable() {
@Override
public void run() {
//执行耗时的操作
Log.w("TAG","Sub Thread:"+Thread.currentThread().getId() + ":" + Thread.currentThread().getName());
}
}).start();
}
}


上面的Log打印如下

4510-4510/com.example.baronli.test W/TAG: Service Thread:1:main
4510-4566/com.example.baronli.test W/TAG: Sub Thread:181:Thread-4


表明Service的onCreate回调方法确实是运行在主线程中。

我们需要在Service中另外开启子线程执行我们的耗时任务。

IntentService使用

IntentService是则是对子线程进行了封装,提供了onHandleIntent()方法,onHandleIntent中的操作默认在子线程中执行

public class MyIntentService extends IntentService {

public MyIntentService() {
super("MyIntentService");
Log.w("TAG", "MyIntentService Thread:" + Thread.currentThread().getId() + ":" + Thread.currentThread().getName());
}

@Override
protected void onHandleIntent(@Nullable Intent intent) {
Log.w("TAG", "onHandleIntent Thread:" + Thread.currentThread().getId() + ":" + Thread.currentThread().getName());
}
}


4510-4510/com.example.baronli.test W/TAG: MyIntentService Thread:1:main
4510-4567/com.example.baronli.test W/TAG: onHandleIntent Thread:182:IntentService[MyIntentService]


通过上面的Log我们可以发现IntentService其实本省的创建等操作也是在主线程中的,而onHandleIntent()方法中的代码则是在子线程中运行。这样就非常方便,我们只需要重写onHandleIntent()方法,在其中写我们的耗时操作就能够实现异步操作了。

注意

IntentService在执行完onHandleIntent()方法中的操作后会自动停止,不需要我们停止(自动调用stopSelf(msg.arg1);)


IntentService是串行执行,多个任务会进行排列,上一个执行完成后执行下一个。

如果多次调用startService()?

IntentService实现原理

IntentService实际上是利用Android的消息机制实现的,就是我们非常熟悉的Handler。

下面我们针对其源发分析一下(源码比较简单)

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(@Nullable Intent intent, int startId) {
Message msg = mServiceHandler.obtainMessage();
msg.arg1 = startId;
msg.obj = intent;
mServiceHandler.sendMessage(msg);
}

@Override
public void onDestroy() {
mServiceLooper.quit();
}

@Override
@Nullable
public IBinder onBind(Intent intent) {
return null;
}

@WorkerThread
protected abstract void onHandleIntent(@Nullable Intent intent);
}


我们重点看一下ServiceHandler的实现

private final class ServiceHandler extends Handler {
public ServiceHandler(Looper looper) {
//此处与我们一般在Activity的写法不同,此处Looper传入的事子线程中的Looper,我们在Activity中并没有此步骤,实质是默认采用的当前Activity所在的主线程的Looper,此处传过来的事子线程的Looper,则
super(looper);
}

@Override
public void handleMessage(Message msg) {
onHandleIntent((Intent)msg.obj);
stopSelf(msg.arg1);
}
}


其实IntentService原理就是实例一个HandlerService,然后每次调用onStartCommand(会回调onStart)的时候给发送一个消息(Message)然后就会在子线程中回调 onHandleIntent((Intent)msg.obj);之后还会调 stopSelf(msg.arg1);
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息