Android知识Android开发经验谈Android开发

IntentService示例代码和源码解析

2017-06-15  本文已影响43人  未见哥哥

IntentService

在实际开发过程中会有这样的一个需求,我们需要运行一个任务,并且只需要在后台默默运行即可,那么这样的需求,我们一般会在 activity 中去开启一个线程,让其去跑这个任务,但是 activity 在被切换到后台并且因为内存不足时会被回收。不过还有一种方式可以解决那就是使用 Service 的方式实现,在 Service 中开启子线程执行耗时操作,并且 service 的优先级高, 不易被回收。不过 google 为了方便开发者使用,提供了一个 IntentService 这个类。下面是 google 对这个类的描述:


/**
 * IntentService is a base class for {@link Service}s that handle asynchronous
 * requests (expressed as {@link Intent}s) on demand.  Clients send requests
 * through {@link android.content.Context#startService(Intent)} calls; the
 * service is started as needed, handles each Intent in turn using a worker
 * thread, and stops itself when it runs out of work.
 *
 * <p>This "work queue processor" pattern is commonly used to offload tasks
 * from an application's main thread.  The IntentService class exists to
 * simplify this pattern and take care of the mechanics.  To use it, extend
 * IntentService and implement {@link #onHandleIntent(Intent)}.  IntentService
 * will receive the Intents, launch a worker thread, and stop the service as
 * appropriate.
 *
 * <p>All requests are handled on a single worker thread -- they may take as
 * long as necessary (and will not block the application's main loop), but
 * only one request will be processed at a time.
 */

简单理解:IntentService是继承Service异步请求任务类,内部维护了HandlerThread和Handler,可用于执行后台耗时任务。所有的请求都只会在一个单一的线程去执行,并且一次只会去执行一个请求,队列的方式顺序执行所有的任务完成之后会自己去停止服务。正在执行的任务是无法被打断的。使用IntentService 的好处就是不需要去手动的关闭服务,也免去了开启线程的工作,使用起来很方便

案例

public class MyIntentService extends IntentService {
    public static final String TAG = MyIntentService.class.getSimpleName();

    public MyIntentService() {
        super(TAG);
    }

    @Override
    protected void onHandleIntent(Intent intent) {
       
        if (intent != null) {
            String task = intent.getStringExtra("task");
            Log.e(TAG,"onHandleIntent:"+task);

            if("open".equals(task)) {
                //表示要处理的意图
                SystemClock.sleep(3000);
                Log.e(TAG,"要特殊处理的意图:"+task);
            }
        }
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        Log.e(TAG, "MyIntentService 被销毁了");
    }
}

Intent service = new Intent(this, MyIntentService.class);

service.putExtra("task", "close1");
startService(service);

service.putExtra("task", "close2");
startService(service);

service.putExtra("task", "open");
startService(service);

从运行结果可以看出IntentService是逐个去执行任务的,只有最后一个任务执行完毕之后才会去停止服务

onHandleIntent:close1
onHandleIntent:close2
onHandleIntent:open
要特殊处理的意图:open
MyIntentService 被销毁了

源码分析

@Override
public void onCreate() {
    super.onCreate();
    HandlerThread thread = new HandlerThread("IntentService[" + mName + "]");
    thread.start();//开启线程

    mServiceLooper = thread.getLooper();//拿到thread 绑定的 Looper 对象
    mServiceHandler = new ServiceHandler(mServiceLooper); //根据 Looper 创建 ServiceHandler 对象。
}
@Override
public void run() {
    mTid = Process.myTid();
    Looper.prepare();
    synchronized (this) {
        mLooper = Looper.myLooper();
        notifyAll();
    }
    Process.setThreadPriority(mPriority);
    onLooperPrepared();
    Looper.loop();
    mTid = -1;
}
@Override
public void onStart(Intent intent, int startId) {
    Message msg = mServiceHandler.obtainMessage();
    msg.arg1 = startId;
    msg.obj = intent;
    mServiceHandler.sendMessage(msg);
}
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);
    }
}
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);//传递当前的id作为当前启动的任务停止服务的标记,不要去调用stopSelf()方法,这样会马上停止服务,有可能其他开启的服务还没执行完毕。
    }
}

ServiceHandler是一个Handler,从onCreate方法可以看出,ServiceHandler是绑定HandlerThread的Looper,也就是说它处于非UI线程,而是跟 HandlerThread 处于同一个线程。当轮训到 Messgae 时,会回调 handleMessage 方法,然后调用 onHandleIntent 将 msg.obj 作为参数传递过去。这个 msg.obj 就是通过 startService 传入的 Intent 对象。

onCreate 方法只会在第一次开启时调用,多次开启服务是不会再次调用 onCreate 方法的,而是会去调用 onStart 方法,因此 IntentService 中的 HandlerThread 是同一个,也就是所有的任务都会一个线程中去执行。并且会共用一个 ServiceHandler 对象。每次开启任务,都会回调 onStart 方法,然后往消息队列中添加一个任务,但是你注意到在 handleMessage 中处理 完 onHandleIntent 之后会调用 stopSelf(msg.arg1) 这是不是意味着服务就被关闭了呢?其实不是,为什么使用 stopSelf(msg.arg1) 可以参考下面一点。

上一篇 下一篇

猜你喜欢

热点阅读