8.1J.U.C-FutureTask
package com.moluo.concurrency.aqs;
import java.util.concurrent.*;
public class FutureExample {
static class MyCallable implements Callable<String> {
@Override
public String call() throws Exception {
System.out.println("do something in callable");
Thread.sleep(5000);
return "done";
}
}
public static void main(String[] args) throws InterruptedException, ExecutionException {
ExecutorService executorService = Executors.newCachedThreadPool();
Future<String> future = executorService.submit(new MyCallable());
System.out.println("do something in main");
Thread.sleep(1000);
String futureTaskResult = future.get();
System.out.println(futureTaskResult);
executorService.shutdown();
}
}FutureTask类
Last updated