35 lines
1.2 KiB
Java
35 lines
1.2 KiB
Java
|
package bunny.async;
|
|||
|
|
|
|||
|
|
import java.util.concurrent.Callable;
|
|||
|
|
import java.util.concurrent.ExecutorService;
|
|||
|
|
import java.util.concurrent.Executors;
|
|||
|
|
import java.util.concurrent.Future;
|
|||
|
|
|
|||
|
|
public class CallableWithFutureTest {
|
|||
|
|
public static void main(String[] args) throws Exception {
|
|||
|
|
try (ExecutorService executorService = Executors.newSingleThreadExecutor()) {
|
|||
|
|
Callable<Integer> task = () -> {
|
|||
|
|
Thread.sleep(1000);
|
|||
|
|
return 42;
|
|||
|
|
};
|
|||
|
|
Future<Integer> future = executorService.submit(task);
|
|||
|
|
|
|||
|
|
// 是否完成
|
|||
|
|
boolean done = future.isDone();
|
|||
|
|
System.out.println("是否完成：" + done);
|
|||
|
|
|
|||
|
|
// 等待任务执行完成并获取结果，方法会阻塞，直到等到结果或者结果超时
|
|||
|
|
Integer result = future.get();
|
|||
|
|
|
|||
|
|
// 取消操作
|
|||
|
|
boolean cancel = future.cancel(true);
|
|||
|
|
System.out.println("是否取消：" + cancel);
|
|||
|
|
|
|||
|
|
// 是否在任务完成前取消，如果是返回true
|
|||
|
|
boolean cancelled = future.isCancelled();
|
|||
|
|
System.out.println("是否在任务完成前取消：" + cancelled);
|
|||
|
|
|
|||
|
|
System.out.println("任务结果: " + result);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|