一個 Android 任務隊列的實現

      最近在做Android項目時遇到這樣一個問題：客戶端向服務器請求數據，而在網絡信號太差的情況下，數據遲遲不到，甚至丟失。服務器為了解決這個問題做了頻繁的重發，android 客戶端就會收到很多不想要的消息；或者因為消息回來太慢，用戶已經失去耐心的去做別的操作了，而那個姍姍來遲的消息的到來就會讓用戶莫名其妙。
      如何有一個類，在向服務器發出請求的時候就向任務隊列中添加一條任務，並啟動，等待時間到了以后就丟棄這個任務；在等待時間內如果有相應的響應消息返回的時候，則停掉該任務就解決了這一難題了。
      下面是任務類：

import java.util.TimerTask;

public class MsgTask extends TimerTask {
    private long deltaTime;  //時間增量，及任務執行等待時間
    private MsgKey msgKey;
    private MsgProcessor msgProcessor = new MsgProcessor();
 
    public MsgTask(MsgKey msgKey,long deltaTime) {
        super();
        this.msgKey = msgKey;
        this.deltaTime = deltaTime;
    }

    public long getDeltaTime() {
        return deltaTime;
    }

    public void setDeltaTime(long deltaTime) {
        this.deltaTime = deltaTime;
    }

    public MsgKey getMsgKey() {
        return msgKey;
    }

    public void setMsgKey(MsgKey msgKey) {
        this.msgKey = msgKey;
    }

    @Override
    public void run() {//等待時間到了以后，就執行
        int index = msgKey.getIndex();
        msgProcessor.dealOverTimeMsg(index);
        MsgManager.removeMsgTask(msgKey);
        this.cancel();
    }
}

為了方便對任務隊列的管理，可以寫一個任務管理類：

import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.Timer;

import android.util.Log;

public class MsgManager {
    private static Timer timer = new Timer();
    private static Map<MsgKey, MsgTask> msgTasks = Collections.synchronizedMap(new HashMap<MsgKey, MsgTask>());

    public static void putMsgTask(MsgKey msgKey,MsgTask msgTask) {
        synchronized (msgTasks) {
            msgTasks.put(msgKey, msgTask);
        }
    }

    public static void startMsgTask(MsgKey msgKey,MsgTask msgTask) {
        putMsgTask(msgKey, msgTask);
        timer.schedule(msgTask, msgTask.getDeltaTime());
        Log.d("zyr",""+msgKey.getIndex());
    }

    public static MsgTask removeMsgTask(MsgKey msgKey) {
        MsgTask msgTask = null;
        synchronized (msgTasks) {
            msgTask = msgTasks.remove(msgKey);
        }
        return msgTask;
    }

    public static boolean stopMsgTask(MsgKey msgKey) {
        MsgTask msgTask = removeMsgTask(msgKey);
        if (msgTask != null){
            msgTask.cancel();
            return true;
        }
        return false;
    }
}

任務需要一個標志，才能方便啟動和結束，下面的MsgKey就是用來標記任務的實體類：

public class MsgKey {
    private int index;

    public int getIndex() {
        return index;
    }

    public void setIndex(int index) {
        this.index = index;
    }
 
    @Override
    public boolean equals(Object obj) {
        if (obj instanceof MsgKey) {
            MsgKey msgKey = (MsgKey) obj;
            return this.index == msgKey.getIndex();
        } else {
            return false;
        }
    }

    @Override
    public int hashCode() {
        return String.valueOf(this.index).hashCode();
    }
}

當然，如果等待超時，一定要有相應的處理的：

public class MsgProcessor {
 
    /**
     * 處理超時的消息
     * @param index
     */
    public void dealOverTimeMsg(int index){
        switch (index) {
        case 0:
             loginOverTimeHandler();
             break;

        default:
             break;
        }
    }
 
    private void loginOverTimeHandler(){
        //這里寫處理方法
    }
}

值得注意的是：如果需要把任務添加到任務隊列后並立即執行，則用startMsgTask方法，結束這個任務時要用stopMsgTask方法，如果沒有這個任務 stopMsgTask返回false；如果需要把任務添加到任務隊列但不確定什么時候執行，則用putMsgTask方法，結束這個任務時就用removeMsgTask方法就可以了，如果沒有這個任務removeMsgTask返回null。