package com.suning.MutliThread;

import java.util.concurrent.Callable;
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;

public class FutureDmeo implements Callable<String> {

    private String name;
    public FutureDmeo(String name) {
        super();
        this.name = name;
    }
    @Override
    public String call() throws Exception {
        // TODO Auto-generated method stub
        TimeUnit.MILLISECONDS.sleep(4000);
        return name+":好人一生平安";
    }
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ExecutorService es=Executors.newFixedThreadPool(3);
        Future<String> f1=es.submit(new FutureDmeo("王彬彬"));
        Future<String> f2=es.submit(new FutureDmeo("習二人"));
        Future<String> f3=es.submit(new FutureDmeo("鑫胖"));
        System.out.println(f1.get());
        System.out.println(f2.get());
        System.out.println(f3.get());
        System.out.println("蒼老師手活很好！"); 
    }
}