股票量化交易接口,completablefuture减少阻塞和轮询，可以传入回调对象，当异步任务完成或者发生异常时，自动调用回调对象的回调方法。
public class CompletableFutureUseDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executorService = Executors.newFixedThreadPool(3);
CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(() -> {
System.out.println(Thread.currentThread().getName() + "---come in");
int result = ThreadLocalRandom.current().nextInt(10);
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
if (result > 5) { //模拟产生异常情况
int i = 10 / 0;
}
System.out.println("----------1秒钟后出结果" + result);
return result;
}, executorService).whenComplete((v, e) -> {
if (e == null) {
System.out.println("计算完成 更新系统" + v);
}
}).exceptionally(e -> {
e.printStackTrace();
System.out.println("异常情况：" + e.getCause() + " " + e.getMessage());
return null;
});
System.out.println(Thread.currentThread().getName() + "先去完成其他任务");
executorService.shutdown();
}
}
/**
* 无异常情况
* pool-1-thread-1---come in
* main先去完成其他任务
* ----------1秒钟后出结果9
* 计算完成 更新系统9
*/
/**
* 有异常情况
*pool-1-thread-1---come in
* main先去完成其他任务
* java.util.concurrent.CompletionException: java.lang.ArithmeticException: / by zero
* 异常情况：java.lang.ArithmeticException: / by zero java.lang.ArithmeticException: / by zero
*/
3Future编码实战和优缺点分析优点：Future+线程池异步多线程任务配合，能显著提高程序的运行效率。缺点：
○get阻塞—一旦调用get方法求结果，一旦调用不见不散，非要等到结果才会离开，不管你是否计算完成，如果没有计算完成容易程序堵塞。○isDone轮询—轮询的方式会耗费无谓的cpu资源，而且也不见得能及时得到计算结果，如果想要异步获取结果，通常会以轮询的方式去获取结果，尽量不要阻塞。
结论：Future对于结果的获取不是很友好，只能通过阻塞或轮询的方式得到任务的结果。
public class FutureApiDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
FutureTask<String> futureTask = new FutureTask<>(() -> {
System.out.println(Thread.currentThread().getName() + "--------come in");
try {
TimeUnit.SECONDS.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "task over";
});
Thread t1 = new Thread(futureTask, "t1");
t1.start();
// System.out.println(futureTask.get());//这样会有阻塞的可能，在程序没有计算完毕的情况下。
System.out.println(Thread.currentThread().getName() + " ------忙其他任务");
// System.out.println(futureTask.get(3,TimeUnit.SECONDS));//只愿意等待三秒，计算未完成直接抛出异常
while (true) {//轮询
if(futureTask.isDone()){
System.out.println(futureTask.get());
break;
}else{
TimeUnit.MILLISECONDS.sleep(500);
System.out.println("正在处理中，不要催了，越催越慢");
}
}
/* 轮询结果
* main ------忙其他任务
t1--------come in
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
正在处理中，不要催了，越催越慢
task over
Process finished with exit code 0
* */
}
}
文章为作者独立观点，不代表股票交易接口观点
相关文章
股民评论