Java_InvokeAll_又返回值_多个线程同时执行，取消超时线程

package com.demo.test4;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

/**
 * @author QQ: 1236897 如果超过限制时间则取消超时线程
 *
 */
public class InvokeDemo {

    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        ExecutorService exec = Executors.newCachedThreadPool();
        List<SearchTask> searchTasks = new ArrayList<SearchTask>();
        SearchTask st = null;
        for (int i = 0; i < 10; i++) {
            st = new SearchTask(i, 200);// 指定2001 毫米为最大执行时间
            if (i == 5)
                st = new SearchTask(i, 2001);// 指定2001 毫米为最大执行时间
            searchTasks.add(st);
        }

        try {
            // 要求认为在2000毫秒内返回结果，否则取消执行。
            List<Future<List<Person>>> futures = exec.invokeAll(searchTasks,
                    2000, TimeUnit.MILLISECONDS);// invokeAll
                                                    // 第一个参数是任务列表；第二个参数是过期时间；第三个是过期时间单位
            int count = 0;
            for (Future<List<Person>> future : futures) {
                try {
                    List<Person> students = future.get();
                    for (Person student : students) {
                        System.out.println(student.toString());
                    }
                } catch (CancellationException e) {
                    System.out.println("cancel");
                    future.cancel(true);
                }
                System.out.println("-----------------------" + count
                        + "--------------------");
                count++;
            }
            exec.shutdown();
        } catch (InterruptedException e) {
            e.printStackTrace();
            Thread.interrupted();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }

}

/**
 * @filename: SearchTask
 * @description: 查询任务
 * @author lida
 * @date 2013-4-1 下午3:02:29
 */
class SearchTask implements Callable<List<Person>> {

    public final int classID;
    public long sleepTime;

    /**
     * <p>
     * Title:
     * </p>
     * <p>
     * Description:
     * </p>
     * 
     * @param classID
     *            班级编号
     * @param sleepTime
     *            模拟操作所用的时间数（毫秒）
     */
    SearchTask(int classID, long sleepTime) {
        this.classID = classID;
        this.sleepTime = sleepTime;
    }

    @Override
    public List<Person> call() throws Exception {
        // 模拟操作所用的时间数（毫秒）
        Thread.sleep(sleepTime);
        List<Person> stuList = new ArrayList<Person>();
        Person p = new Person(1, "name", 2);
        Person p2 = new Person(2, "name", 3);
        stuList.add(p);
        stuList.add(p2);
        return stuList;
    }

}

class Person {
    private int id;
    private String name;
    private int classID;

    public Person(int id, String name, int classID) {
        this.id = id;
        this.name = name;
        this.classID = classID;
    }

    public String toString() {
        return Person.class.getName() + "(id:" + this.id + ",name:" + this.name
                + ")";
    }

}