Java中限时线程回调方式的实现

中国IT实验室收集整理

佚名

2007-11-8

保存本文

推荐给好友

收藏本页

　　线程回调方式我们已经在"使用回调和线程处理一个耗时响应过程"文中进行了讲述，但是有些情况下用户希望在指定时间内返回一个结果，免得无休止的等待下去。这时我们需要使用"限时线程回调方式"，它在原有线程回调的基础上加上了一个Timer以计算消耗的时间，如果时间期限到了任务还没有执行完的话即中断线程，示例代码如下：

package com.sitinspring;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;

import javax.swing.Timer;

/** *//**
 * 定时回调线程类
 * 
 * @author sitinspring(junglesong@gmail.com)
 * 
 * @date 2007-11-6
 */
public class TimedCallBackThread implements Runnable {
    // 一秒的毫秒数常量
  private final static int ONE_SECOND = 1000;

    // 限制时间,以秒为单位
  private final int waitTime;

    // 已经流逝的时间
  private int passedTime;

  private Timer timer;

  private Thread thread;

  private MvcTcModel model;

  private MvcTcView view;

  public TimedCallBackThread(MvcTcModel model, MvcTcView view, int waitTime)
      {
        this.model = model;
        this.view = view;
        this.waitTime = waitTime;
        this.passedTime = 0;

        // 创建并启动定时器
        timer = new Timer(ONE_SECOND, new ActionListener() {
            public void actionPerformed(ActionEvent evt) {
                timeListener();
            }
        });
        timer.start();

        // 创建并启动线程来完成任务
        thread = new Thread(this);
        thread.start();
    }

    private void timeListener() {
        passedTime++;

        // 动态显示状态
        int modSeed = passedTime % 3;
        if (modSeed == 0) {
            view.getLabel2().setText("响应中");
        } else if (modSeed == 1) {
            view.getLabel2().setText("响应中..");
        } else if (modSeed == 2) {
            view.getLabel2().setText("响应中.");
        }

        // 如果流逝时间大于规定时间则中断线程
        if (passedTime > waitTime) {
            passedTime = waitTime;
            thread.interrupt();
        }
    }

    public void run() {
        while (passedTime < waitTime) {
            try {
                Thread.sleep(10000);// 模拟一个耗时相应过程
                timer.stop();// 任务完成,停止Timer

                view.getLabel2().setText(model.getText2());
            } catch (InterruptedException ex) {
                timer.stop();// 线程中断,停止Timer
                view.getLabel2().setText("在指定时间内未响应");
            } catch (Exception ex) {
                ex.printStackTrace();
            }

            return;
        }
    }
}

　　执行效果如下：