线程池例子

public class TestThread {

public static void main(String[] args) throws InterruptedException, ExecutionException {

ExecutorService service = Executors.newSingleThreadExecutor();

Future<String> future = service.submit(new Call());

String result = future.get();

System.out.println(result);

System.out.println("-----finish----------");

service.shutdown();

}

}

class Call implements java.util.concurrent.Callable<String>{

@Override

public String call() throws Exception {

TimeUnit.SECONDS.sleep(5);

return "I am running.";

}

}