Android 異步任務知識梳理(3) AsyncQueryHandler 源碼解析

1、概述

AsyncQueryHandler方便了咱們對ContentProvider進行增、刪、改、查，此外，咱們經過學習它的原理能夠更好地理解HandlerThread，學習如何在項目中使用它。

2、源碼

AsyncQueryHandler中的關鍵是mWorkerThreadHandler，它在其handleMessage中進行操做，由於它在構造時傳入的Looper所關聯的Thread並非主線程，所以全部在handleMessage中的操做都是異步的，這個變量的初始化時在其構造函數中：

public AsyncQueryHandler(ContentResolver cr) {    
    super();    
    mResolver = new WeakReference<ContentResolver>(cr);    
    synchronized (AsyncQueryHandler.class) {        
        if (sLooper == null) {            
            HandlerThread thread = new HandlerThread("AsyncQueryWorker");            
            thread.start();            
            sLooper = thread.getLooper();        
        }    
    }    
    mWorkerThreadHandler = createHandler(sLooper);
}

protected Handler createHandler(Looper looper) {    
    return new WorkerHandler(looper);
}
複製代碼

能夠看到sLooper只有在第一次實例化AsyncQueryHandler纔會生成，所以當咱們採用默認實現時，而且在多個地方實例化不一樣的AsyncQueryHandler對象，每一個對象對應的是不一樣的WorkerHandler，可是 WorkerHandler關聯到的是同一個Looper，咱們經過它執行的全部任務是放在一個隊列當中順序執行的。若是咱們不但願運行在默認的Looper中，那麼也能夠經過重寫createHandler來傳入一個另外的 Looper。由於AsyncQueueHandler的增、刪、改、查的原理都是相同的，所以咱們單獨看一下增長的操做，就能夠理解它的思想了：

public final void startInsert(int token, Object cookie, Uri uri, ContentValues initialValues) {     
    Message msg = mWorkerThreadHandler.obtainMessage(token);    
    msg.arg1 = EVENT_ARG_INSERT;    
    WorkerArgs args = new WorkerArgs();    
    args.handler = this;    
    args.uri = uri;    
    args.cookie = cookie;    
    args.values = initialValues;    
    msg.obj = args;    
    mWorkerThreadHandler.sendMessage(msg);
}

protected class WorkerHandler extends Handler {    
    public WorkerHandler(Looper looper) {         
        super(looper);    
    }
    public void handleMessage(Message msg) {
        final ContentResolver resolver = mResolver.get();
        if (resolver == null) return;
        WorkerArgs args = (WorkerArgs) msg.obj;
          int token = msg.what;
          int event = msg.arg1;
          switch (event) {
              case EVENT_ARG_INSERT:    
                  args.result = resolver.insert(args.uri, args.values);    
                  break;
          }
          Message reply = args.handler.obtainMessage(token);
          reply.obj = args;
          reply.arg1 = msg.arg1;
          reply.sendToTarget();
    }
}

@Override
public void handleMessage(Message msg) {    
    WorkerArgs args = (WorkerArgs) msg.obj;
    int token = msg.what;
    int event = msg.arg1;
    switch (event) {
        case EVENT_ARG_INSERT:    
            onInsertComplete(token, args.cookie, (Uri) args.result);    
            break;
    }
}
複製代碼

當咱們調用了插入方法以後，整個過程以下：

• mWorkerThreadHandler發送一條消息，該消息當中帶有插入相關的全部參數以及**AsyncQueryHandler子類的實例**。
• 在mWorkderThreadHanlder的handleMessage中，它調用ContentResolver的對應插入方法進行插入，它和mWorkderThreadHandler關聯的Looper是運行在同一個線程當中的。
• 插入完畢以後，經過消息當中傳入的AsyncQueryHandler子類的實例將執行的結果發送回去，在其AsyncQueryHandler的handleMessage(Message message)方法中，回調抽象方法onInsertComplete(token, args.cookie, (Uri) args.result)，子類經過實現該方法來獲取執行的結果。