微信输入状态

在微信中，当和别人进行聊天时，如果对方正在输入文字，我们可以看到对方的输入状态。

微信正在输入状态

如果这时对方将输入的文字清空或发送后，则正在输入状态消失。这个过程是这样的：

• A向B发送文字消息，当A输入文字的EditText有内容，A向B发送一个消息包X，这个消息包X代表着“正在输入状态”。
  再对A的输入状态定时进行检测，假设5s检测一下，如果5s后发现EditText还是不为空，再发送消息包X，如果EditText内容为空，发送另外一个消息包Y，这个消息包Y代表着“消息发送取消”。
  如果点击发送按钮，则发送文本消息包Z。

• B接收A的消息，当B收到消息包X后，在界面显示“对方正在输入”，为防止因为网络原因没有接收到Y或者Z消息包而一直显示输入状态，B会马上启动一个定时任务，代号“TASK”，清空显示着的发送状态，这个定时时间会大于A的发送周期，假设6s。即B接到消息包X后马上发送一个6s后清空显示着的发送状态的TASK。
  如果B在6s内接到消息包X，则取消上面的TASK并启动新的TASK。
  如果B在6s内没接到消息包X，则TASK将输入状态清空。微信中这是显示的应该是A的昵称。
  如果B接收到消息包Y，则将输入状态清空。
  如果B接收到消息包Z，则将输入状态清空，显示A发送的文本消息。

让TASK在一段时间后执行，并且可以在执行前取消。这个时候就可以使用Timer或者ScheduledExecutorService。先讲讲Timer。

Timer##

Timer定时器实际上是个线程，定时调度所拥有的TimerTask。需要定时执行的代码放到run方法体内。
先看个简单的例子：

public class ScheduleTask {
    static TimerTask task = new TimerTask() {
        @Override
        public void run() {
            System.out.println("Execut Task Time:" + System.currentTimeMillis());
        }
    };
    
    public static void main(String[] args) {
        long beginTime = System.currentTimeMillis();
        System.out.println("Application Begin Time:" + beginTime);
        Timer timer1 = new Timer();
        timer1.schedule(task, 1000);
    }
}

执行结果可以看到任务在延迟1s后执行了：

Application Begin Time:1420366178189
Execut Task Time:1420366179190

在Timer类中schedule()方法如下：

1. Timer.schedule(TimerTask task,Date time)在制定的时间执行指定的任务

• Timer.schedule(TimerTask task,Date firstTime ,long period)在指定的时间开始进行，之后重复的延迟执行
• Timer.schedule(TimerTask task,long delay)在延迟后执行任务
• Timer.schedule(TimerTask task,long delay,long period)从延迟后开始进行，之后重复的延迟执行
• Timer.scheduleAtFixedRate(TimerTask task,Date firstTime,long period)任务在指定的时间开始进行重复的固定速率执行
• Timer.scheduleAtFixedRate(TimerTask task,long delay,long period)任务在指定的延迟后开始进行重复的固定速率执行

其中schedule与scheduleAtFixedRate的使用还是有区别的：
schedule：适用于那些需要“平稳”运行的重复执行活动。换句话说，它适用于在短期运行中保持频率准确要比在长期运行中更为重要的活动。这包括大多数动画任务，如以固定时间间隔闪烁的光标。这还包括为响应人类活动所执行的固定活动，如在按住键时自动重复输入字符。
scheduleAtFixedRate：适用于那些对绝对时间敏感的重复执行活动，如每小时准点打钟报时，或者在每天的特定时间运行已安排的维护活动。它还适用于那些完成固定次数执行的总计时间很重要的重复活动，如倒计时的计时器，每秒钟滴答一次，共10 秒钟。最后，固定速率执行适用于安排多个重复执行的计时器任务，这些任务相互之间必须保持同步。
在Timer类中还有一个比较常用的方法就是cancel()，用于终止定时任务。

ScheduledExecutorService##

ScheduledExecutorService有四个方法：

ScheduledExecutorService的方法
方法与上面的相似，这次就不做解释了，注意看这四个方法返回的类型都为ScheduledFuture<?>，而interface ScheduledFuture<V> extends Delayed, Future<V>所以取消任务方法在Future中。
Future的方法
直接看例子，以最开始说的用户B收到消息X为例，在项目中的用法为：

if (receivedStatus == Presence.STATUS_TEXT){
    // 1. 第一次接到STATUS_TEXT，将abTabTitleText设置成“对方正在输入...”
    // 2. 4.5s后调度执行showConnectionState (之所以是4.5秒 是因为发送那边的间隔是4秒)
    // 3. 再次接到STATUS_TEXT，将上一个调度取消
    // 4. 执行2调度
    abTabTitleText.setText("对方正在输入...");
    if (textRecevieTaskCount > 0){
        cancelTextRecevieFuture();
    }

    scheduleTextRecevie();
    textRecevieTaskCount ++;

收到消息后马上执行scheduleTextRecevie()方法：

 private void scheduleTextRecevie(){
        textRecevieTaskFuture = executor.schedule(new Runnable() {
            @Override
            public void run() {
                mainHandler.post(new Runnable() {
                    @Override
                    public void run() {
                        if (textRecevieTaskFuture != null){
                            showConnectionState();
                            textRecevieTaskCount = 0;
                            textRecevieTaskFuture = null;
                        }
                    }
                });
            }
        }, 4500L, TimeUnit.MILLISECONDS);
   }    

取消任务方法为：

 private void cancelTextRecevieFuture(){
        if (textRecevieTaskFuture != null){
            textRecevieTaskFuture.cancel(true);
            textRecevieTaskFuture = null;
        }
  }