ExecutorService ser = Executors.newFixedThreadPool(2);
Future result = ser.submit(實(shí)現(xiàn)類對象)

package multi_Thread;
import java.util.concurrent.*;
/**
 * 使用Callable創(chuàng)建線程
 * Created by dd on 2016/6/4 0004.
 */
public class demo01 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
//        創(chuàng)建線程
        ExecutorService ser = Executors.newFixedThreadPool(2);
        Race tortoise = new Race("烏龜",1000);
        Race rabbit = new Race("兔子",500);
        Future<Integer> result1 = ser.submit(tortoise);
        Future<Integer> result2 = ser.submit(rabbit);
        Thread.sleep(2000);
        tortoise.setFlag(false);
        rabbit.setFlag(false);
//        獲取值
        Integer num1 = result1.get();
        Integer num2 = result2.get();
        System.out.println("烏龜"+num1);
        System.out.println("兔子"+num2);
//        停止服務(wù)
        ser.shutdownNow();
    }
}
class Race implements Callable<Integer>{
    private String name;//名稱
    private long time;//延時(shí)時(shí)間
    private boolean flag = true;
    private int step = 0;
    public Race() {
    }
    public Race(String name) {
        super();
        this.name = name;
    }
    public Race(String name, long time) {
        super();
        this.name = name;
        this.time = time;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public long getTime() {
        return time;
    }
    public void setTime(long time) {
        this.time = time;
    }
    public boolean isFlag() {
        return flag;
    }
    public void setFlag(boolean flag) {
        this.flag = flag;
    }
    public int getStep() {
        return step;
    }
    public void setStep(int step) {
        this.step = step;
    }
    @Override
    public Integer call() throws Exception {
        while (flag){
            Thread.sleep(time);
            step++;
        }
        return step;
    }
}