Future：可以获取到异步结果
作用：一个大业务，里面顺序执行太慢。用此可以同时异步兼并执行
public class CompletableFutureTest {
public static ExecutorService executorService = Executors.newFixedThreadPool(10);
public static void main(String[] args) throws ExecutionException, InterruptedException {
System.out.println("main...start...");
//传入Runnable和线程池
CompletableFuture.runAsync(() -> {
System.out.println("当前线程:" + Thread.currentThread().getId());
int i = 10 / 2;
System.out.println("运行结果:" + i);
}, executorService);
//有返回值的异步任务
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
System.out.println("当前线程:" + Thread.currentThread().getId());
int i = 10 / 0;
System.out.println("运行结果:" + i);
return i;
}, executorService)
// .whenComplete((result,error)->{//参数1是结果，2是一成
// System.out.println("异步任务完成...");
// System.out.println("结果是..."+result);
// System.out.println("异常是..."+error);//感知了异常，但无法返回修正数据
// }).exceptionally(throwable -> {
// return 10;//如果出现异常，这里可以返回修正数据。如果不返回就不要写这里
// })
.handle((result, error) -> {//同时完成上述两步，可与上面独立开
System.out.println("异步任务完成...");
if (result != null) return result * 2;
if (error != null) return 0;
return 0;
});
System.out.println("修正数据(如果异常):" + future.get());
System.out.println("main...end...");
}
}
"C:\Program Files\Java\jdk1.8.0_321\bin\java.exe" "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2021.3.2\lib\idea_rt.jar=1922:C:\Program Files\JetBrains\IntelliJ IDEA 2021.3.2\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_321\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_321\jre\lib\rt.jar;C:\project\gulimail\gulimall-search\target\classes;C:\repo\org\springframework\boot\spring-boot-starter-web\2.3.12.RELEASE\spring-boot-starter-web-2.3.12.RELEASE.jar;C:\repo\org\springframework\boot\spring-boot-starter\2.3.12.RELEASE\spring-boot-starter-2.3.12.RELEASE.jar;C:\repo\org\springframework\boot\spring-boot-starter-logging\2.3.12.RELEASE\spring-boot-starter-logging-2.3.12.RELEASE.jar;C:\repo\ch\qos\logback\logback-classic\1.2.3\logback-classic-1.2.3.jar;C:\repo\ch\qos\logback\logback-core\1.2.3\logback-core-1.2.3.jar;C:\repo\org\apache\logging\log4j\log4j-to-slf4j\2.13.3\log4j-to-slf4j-2.13.3.jar;C:\repo\org\slf4j\jul-to-slf4j\1.7.30\jul-to-slf4j-1.7.30.jar;C:\repo\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;C:\repo\org\yaml\snakeyaml\1.26\snakeyaml-1.26.jar;C:\repo\org\springframework\boot\spring-boot-starter-json\2.3.12.RELEASE\spring-boot-starter-json-2.3.12.RELEASE.jar;C:\repo\com\fasterxml\jackson\core\jackson-databind\2.11.4\jackson-databind-2.11.4.jar;C:\repo\com\fasterxml\jackson\core\jackson-annotations\2.11.4\jackson-annotations-2.11.4.jar;C:\repo\com\fasterxml\jackson\core\jackson-core\2.11.4\jackson-core-2.11.4.jar;C:\repo\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.11.4\jackson-datatype-jdk8-2.11.4.jar;C:\repo\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.11.4\jackson-datatype-jsr310-2.11.4.jar;C:\repo\com\fasterxml\jackson\module\jackson-module-parameter-names\2.11.4\jackson-module-parameter-names-2.11.4.jar;C:\repo\org\springframework\boot\spring-boot-starter-tomcat\2.3.12.RELEASE\spring-boot-starter-tomcat-2.3.12.RELEASE.jar;C:\repo\org\apache\tomcat\embed\tomcat-embed-core\9.0.46\tomcat-embed-core-9.0.46.jar;C:\repo\org\glassfish\jakarta.el\3.0.3\jakarta.el-3.0.3.jar;C:\repo\org\apache\tomcat\embed\tomcat-embed-websocket\9.0.46\tomcat-embed-websocket-9.0.46.jar;C:\repo\org\springframework\spring-web\5.2.15.RELEASE\spring-web-5.2.15.RELEASE.jar;C:\repo\org\springframework\spring-beans\5.2.15.RELEASE\spring-beans-5.2.15.RELEASE.jar;C:\repo\org\springframework\spring-webmvc\5.2.15.RELEASE\spring-webmvc-5.2.15.RELEASE.jar;C:\repo\org\springframework\spring-aop\5.2.15.RELEASE\spring-aop-5.2.15.RELEASE.jar;C:\repo\org\springframework\spring-context\5.2.15.RELEASE\spring-context-5.2.15.RELEASE.jar;C:\repo\org\springframework\spring-expression\5.2.15.RELEASE\spring-expression-5.2.15.RELEASE.jar;C:\repo\org\slf4j\slf4j-api\1.7.30\slf4j-api-1.7.30.jar;C:\repo\org\springframework\spring-core\5.2.15.RELEASE\spring-core-5.2.15.RELEASE.jar;C:\repo\org\springframework\spring-jcl\5.2.15.RELEASE\spring-jcl-5.2.15.RELEASE.jar;C:\repo\org\elasticsearch\client\elasticsearch-rest-high-level-client\7.4.2\elasticsearch-rest-high-level-client-7.4.2.jar;C:\repo\org\elasticsearch\elasticsearch\7.4.2\elasticsearch-7.4.2.jar;C:\repo\org\elasticsearch\elasticsearch-core\7.4.2\elasticsearch-core-7.4.2.jar;C:\repo\org\elasticsearch\elasticsearch-secure-sm\7.4.2\elasticsearch-secure-sm-7.4.2.jar;C:\repo\org\elasticsearch\elasticsearch-x-content\7.4.2\elasticsearch-x-content-7.4.2.jar;C:\repo\com\fasterxml\jackson\dataformat\jackson-dataformat-smile\2.11.4\jackson-dataformat-smile-2.11.4.jar;C:\repo\com\fasterxml\jackson\dataformat\jackson-dataformat-yaml\2.11.4\jackson-dataformat-yaml-2.11.4.jar;C:\repo\com\fasterxml\jackson\dataformat\jackson-dataformat-cbor\2.11.4\jackson-dataformat-cbor-2.11.4.jar;C:\repo\org\elasticsearch\elasticsearch-geo\7.4.2\elasticsearch-geo-7.4.2.jar;C:\repo\org\apache\lucene\lucene-core\8.2.0\lucene-core-8.2.0.jar;C:\repo\org\apache\lucene\lucene-analyzers-common\8.2.0\lucene-analyzers-common-8.2.0.jar;C:\repo\org\apache\lucene\lucene-backward-codecs\8.2.0\lucene-backward-codecs-8.2.0.jar;C:\repo\org\apache\lucene\lucene-grouping\8.2.0\lucene-grouping-8.2.0.jar;C:\repo\org\apache\lucene\lucene-highlighter\8.2.0\lucene-highlighter-8.2.0.jar;C:\repo\org\apache\lucene\lucene-join\8.2.0\lucene-join-8.2.0.jar;C:\repo\org\apache\lucene\lucene-memory\8.2.0\lucene-memory-8.2.0.jar;C:\repo\org\apache\lucene\lucene-misc\8.2.0\lucene-misc-8.2.0.jar;C:\repo\org\apache\lucene\lucene-queries\8.2.0\lucene-queries-8.2.0.jar;C:\repo\org\apache\lucene\lucene-queryparser\8.2.0\lucene-queryparser-8.2.0.jar;C:\repo\org\apache\lucene\lucene-sandbox\8.2.0\lucene-sandbox-8.2.0.jar;C:\repo\org\apache\lucene\lucene-spatial\8.2.0\lucene-spatial-8.2.0.jar;C:\repo\org\apache\lucene\lucene-spatial-extras\8.2.0\lucene-spatial-extras-8.2.0.jar;C:\repo\org\apache\lucene\lucene-spatial3d\8.2.0\lucene-spatial3d-8.2.0.jar;C:\repo\org\apache\lucene\lucene-suggest\8.2.0\lucene-suggest-8.2.0.jar;C:\repo\org\elasticsearch\elasticsearch-cli\7.4.2\elasticsearch-cli-7.4.2.jar;C:\repo\net\sf\jopt-simple\jopt-simple\5.0.2\jopt-simple-5.0.2.jar;C:\repo\com\carrotsearch\hppc\0.8.1\hppc-0.8.1.jar;C:\repo\joda-time\joda-time\2.10.3\joda-time-2.10.3.jar;C:\repo\com\tdunning\t-digest\3.2\t-digest-3.2.jar;C:\repo\org\hdrhistogram\HdrHistogram\2.1.9\HdrHistogram-2.1.9.jar;C:\repo\org\apache\logging\log4j\log4j-api\2.13.3\log4j-api-2.13.3.jar;C:\repo\org\elasticsearch\jna\4.5.1\jna-4.5.1.jar;C:\repo\org\elasticsearch\client\elasticsearch-rest-client\7.4.2\elasticsearch-rest-client-7.4.2.jar;C:\repo\org\apache\httpcomponents\httpclient\4.5.13\httpclient-4.5.13.jar;C:\repo\org\apache\httpcomponents\httpasyncclient\4.1.4\httpasyncclient-4.1.4.jar;C:\repo\org\apache\httpcomponents\httpcore-nio\4.4.14\httpcore-nio-4.4.14.jar;C:\repo\commons-codec\commons-codec\1.14\commons-codec-1.14.jar;C:\repo\org\elasticsearch\plugin\mapper-extras-client\7.4.2\mapper-extras-client-7.4.2.jar;C:\repo\org\elasticsearch\plugin\parent-join-client\7.4.2\parent-join-client-7.4.2.jar;C:\repo\org\elasticsearch\plugin\aggs-matrix-stats-client\7.4.2\aggs-matrix-stats-client-7.4.2.jar;C:\repo\org\elasticsearch\plugin\rank-eval-client\7.4.2\rank-eval-client-7.4.2.jar;C:\repo\org\elasticsearch\plugin\lang-mustache-client\7.4.2\lang-mustache-client-7.4.2.jar;C:\repo\com\github\spullara\mustache\java\compiler\0.9.3\compiler-0.9.3.jar;C:\project\gulimail\gulimall-common\target\classes;C:\repo\com\baomidou\mybatis-plus-boot-starter\3.2.0\mybatis-plus-boot-starter-3.2.0.jar;C:\repo\com\baomidou\mybatis-plus\3.2.0\mybatis-plus-3.2.0.jar;C:\repo\com\baomidou\mybatis-plus-extension\3.2.0\mybatis-plus-extension-3.2.0.jar;C:\repo\com\baomidou\mybatis-plus-core\3.2.0\mybatis-plus-core-3.2.0.jar;C:\repo\com\baomidou\mybatis-plus-annotation\3.2.0\mybatis-plus-annotation-3.2.0.jar;C:\repo\com\github\jsqlparser\jsqlparser\2.1\jsqlparser-2.1.jar;C:\repo\org\mybatis\mybatis\3.5.2\mybatis-3.5.2.jar;C:\repo\org\mybatis\mybatis-spring\2.0.2\mybatis-spring-2.0.2.jar;C:\repo\org\springframework\boot\spring-boot-starter-jdbc\2.3.12.RELEASE\spring-boot-starter-jdbc-2.3.12.RELEASE.jar;C:\repo\com\zaxxer\HikariCP\3.4.5\HikariCP-3.4.5.jar;C:\repo\org\springframework\spring-jdbc\5.2.15.RELEASE\spring-jdbc-5.2.15.RELEASE.jar;C:\repo\org\springframework\spring-tx\5.2.15.RELEASE\spring-tx-5.2.15.RELEASE.jar;C:\repo\org\projectlombok\lombok\1.18.20\lombok-1.18.20.jar;C:\repo\org\apache\httpcomponents\httpcore\4.4.14\httpcore-4.4.14.jar;C:\repo\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;C:\repo\mysql\mysql-connector-java\8.0.25\mysql-connector-java-8.0.25.jar;C:\repo\com\alibaba\cloud\spring-cloud-starter-alibaba-nacos-discovery\2.2.7.RELEASE\spring-cloud-starter-alibaba-nacos-discovery-2.2.7.RELEASE.jar;C:\repo\com\alibaba\cloud\spring-cloud-alibaba-commons\2.2.7.RELEASE\spring-cloud-alibaba-commons-2.2.7.RELEASE.jar;C:\repo\com\alibaba\nacos\nacos-client\2.0.3\nacos-client-2.0.3.jar;C:\repo\org\reflections\reflections\0.9.11\reflections-0.9.11.jar;C:\repo\org\javassist\javassist\3.21.0-GA\javassist-3.21.0-GA.jar;C:\repo\io\prometheus\simpleclient\0.5.0\simpleclient-0.5.0.jar;C:\repo\com\alibaba\spring\spring-context-support\1.0.10\spring-context-support-1.0.10.jar;C:\repo\org\springframework\cloud\spring-cloud-context\2.2.9.RELEASE\spring-cloud-context-2.2.9.RELEASE.jar;C:\repo\org\springframework\cloud\spring-cloud-starter-netflix-ribbon\2.2.9.RELEASE\spring-cloud-starter-netflix-ribbon-2.2.9.RELEASE.jar;C:\repo\org\springframework\cloud\spring-cloud-starter-netflix-archaius\2.2.9.RELEASE\spring-cloud-starter-netflix-archaius-2.2.9.RELEASE.jar;C:\repo\com\netflix\ribbon\ribbon\2.3.0\ribbon-2.3.0.jar;C:\repo\com\netflix\ribbon\ribbon-transport\2.3.0\ribbon-transport-2.3.0.jar;C:\repo\io\reactivex\rxnetty-contexts\0.4.9\rxnetty-contexts-0.4.9.jar;C:\repo\io\reactivex\rxnetty-servo\0.4.9\rxnetty-servo-0.4.9.jar;C:\repo\javax\inject\javax.inject\1\javax.inject-1.jar;C:\repo\io\reactivex\rxnetty\0.4.9\rxnetty-0.4.9.jar;C:\repo\com\netflix\ribbon\ribbon-core\2.3.0\ribbon-core-2.3.0.jar;C:\repo\com\netflix\ribbon\ribbon-httpclient\2.3.0\ribbon-httpclient-2.3.0.jar;C:\repo\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;C:\repo\com\sun\jersey\jersey-client\1.19.1\jersey-client-1.19.1.jar;C:\repo\com\sun\jersey\jersey-core\1.19.1\jersey-core-1.19.1.jar;C:\repo\javax\ws\rs\jsr311-api\1.1.1\jsr311-api-1.1.1.jar;C:\repo\com\sun\jersey\contribs\jersey-apache-client4\1.19.1\jersey-apache-client4-1.19.1.jar;C:\repo\com\netflix\servo\servo-core\0.12.21\servo-core-0.12.21.jar;C:\repo\com\netflix\netflix-commons\netflix-commons-util\0.3.0\netflix-commons-util-0.3.0.jar;C:\repo\com\netflix\ribbon\ribbon-loadbalancer\2.3.0\ribbon-loadbalancer-2.3.0.jar;C:\repo\com\netflix\netflix-commons\netflix-statistics\0.1.1\netflix-statistics-0.1.1.jar;C:\repo\io\reactivex\rxjava\1.3.8\rxjava-1.3.8.jar;C:\repo\com\alibaba\cloud\spring-cloud-starter-alibaba-nacos-config\2.2.7.RELEASE\spring-cloud-starter-alibaba-nacos-config-2.2.7.RELEASE.jar;C:\repo\org\springframework\boot\spring-boot-starter-validation\2.3.12.RELEASE\spring-boot-starter-validation-2.3.12.RELEASE.jar;C:\repo\org\hibernate\validator\hibernate-validator\6.1.7.Final\hibernate-validator-6.1.7.Final.jar;C:\repo\jakarta\validation\jakarta.validation-api\2.0.2\jakarta.validation-api-2.0.2.jar;C:\repo\org\jboss\logging\jboss-logging\3.4.2.Final\jboss-logging-3.4.2.Final.jar;C:\repo\com\fasterxml\classmate\1.5.1\classmate-1.5.1.jar;C:\repo\javax\validation\validation-api\2.0.1.Final\validation-api-2.0.1.Final.jar;C:\repo\com\alibaba\fastjson\1.2.72\fastjson-1.2.72.jar;C:\repo\org\springframework\boot\spring-boot-starter-thymeleaf\2.3.12.RELEASE\spring-boot-starter-thymeleaf-2.3.12.RELEASE.jar;C:\repo\org\thymeleaf\thymeleaf-spring5\3.0.12.RELEASE\thymeleaf-spring5-3.0.12.RELEASE.jar;C:\repo\org\thymeleaf\thymeleaf\3.0.12.RELEASE\thymeleaf-3.0.12.RELEASE.jar;C:\repo\org\attoparser\attoparser\2.0.5.RELEASE\attoparser-2.0.5.RELEASE.jar;C:\repo\org\unbescape\unbescape\1.1.6.RELEASE\unbescape-1.1.6.RELEASE.jar;C:\repo\org\thymeleaf\extras\thymeleaf-extras-java8time\3.0.4.RELEASE\thymeleaf-extras-java8time-3.0.4.RELEASE.jar;C:\repo\org\springframework\boot\spring-boot-devtools\2.3.12.RELEASE\spring-boot-devtools-2.3.12.RELEASE.jar;C:\repo\org\springframework\boot\spring-boot\2.3.12.RELEASE\spring-boot-2.3.12.RELEASE.jar;C:\repo\org\springframework\boot\spring-boot-autoconfigure\2.3.12.RELEASE\spring-boot-autoconfigure-2.3.12.RELEASE.jar;C:\repo\org\springframework\cloud\spring-cloud-starter-openfeign\2.2.9.RELEASE\spring-cloud-starter-openfeign-2.2.9.RELEASE.jar;C:\repo\org\springframework\cloud\spring-cloud-starter\2.2.9.RELEASE\spring-cloud-starter-2.2.9.RELEASE.jar;C:\repo\org\springframework\security\spring-security-rsa\1.0.9.RELEASE\spring-security-rsa-1.0.9.RELEASE.jar;C:\repo\org\bouncycastle\bcpkix-jdk15on\1.64\bcpkix-jdk15on-1.64.jar;C:\repo\org\bouncycastle\bcprov-jdk15on\1.64\bcprov-jdk15on-1.64.jar;C:\repo\org\springframework\cloud\spring-cloud-openfeign-core\2.2.9.RELEASE\spring-cloud-openfeign-core-2.2.9.RELEASE.jar;C:\repo\org\springframework\cloud\spring-cloud-netflix-ribbon\2.2.9.RELEASE\spring-cloud-netflix-ribbon-2.2.9.RELEASE.jar;C:\repo\org\springframework\cloud\spring-cloud-netflix-archaius\2.2.9.RELEASE\spring-cloud-netflix-archaius-2.2.9.RELEASE.jar;C:\repo\org\springframework\boot\spring-boot-starter-aop\2.3.12.RELEASE\spring-boot-starter-aop-2.3.12.RELEASE.jar;C:\repo\org\aspectj\aspectjweaver\1.9.6\aspectjweaver-1.9.6.jar;C:\repo\io\github\openfeign\form\feign-form-spring\3.8.0\feign-form-spring-3.8.0.jar;C:\repo\io\github\openfeign\form\feign-form\3.8.0\feign-form-3.8.0.jar;C:\repo\commons-fileupload\commons-fileupload\1.4\commons-fileupload-1.4.jar;C:\repo\commons-io\commons-io\2.2\commons-io-2.2.jar;C:\repo\org\springframework\cloud\spring-cloud-commons\2.2.9.RELEASE\spring-cloud-commons-2.2.9.RELEASE.jar;C:\repo\org\springframework\security\spring-security-crypto\5.3.9.RELEASE\spring-security-crypto-5.3.9.RELEASE.jar;C:\repo\io\github\openfeign\feign-core\10.12\feign-core-10.12.jar;C:\repo\io\github\openfeign\feign-slf4j\10.12\feign-slf4j-10.12.jar;C:\repo\io\github\openfeign\feign-hystrix\10.12\feign-hystrix-10.12.jar;C:\repo\com\netflix\archaius\archaius-core\0.7.7\archaius-core-0.7.7.jar;C:\repo\com\google\code\findbugs\jsr305\3.0.1\jsr305-3.0.1.jar;C:\repo\commons-configuration\commons-configuration\1.8\commons-configuration-1.8.jar;C:\repo\com\google\guava\guava\30.0-jre\guava-30.0-jre.jar;C:\repo\com\google\guava\failureaccess\1.0.1\failureaccess-1.0.1.jar;C:\repo\com\google\guava\listenablefuture\9999.0-empty-to-avoid-conflict-with-guava\listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar;C:\repo\org\checkerframework\checker-qual\3.5.0\checker-qual-3.5.0.jar;C:\repo\com\google\errorprone\error_prone_annotations\2.3.4\error_prone_annotations-2.3.4.jar;C:\repo\com\google\j2objc\j2objc-annotations\1.3\j2objc-annotations-1.3.jar;C:\repo\com\netflix\hystrix\hystrix-core\1.5.18\hystrix-core-1.5.18.jar" com.atguigu.gulimall.search.controller.thread.CompletableFutureTest
main...start...
当前线程:11
运行结果:5
当前线程:12
异步任务完成...
修正数据(如果异常):0
main...end...
串行化：thenRunAsync
但是注意无法感知上一步的运行结果，无返回值
CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {
System.out.println("线程1:" + Thread.currentThread().getId());
int i = 10 / 4;
System.out.println("运行结果:" + i);
return i;
}, executorService).thenRunAsync(()->{
System.out.println("线程2:"+Thread.currentThread().getId());//没有返回值可以返回void
},executorService);
System.out.println("修正数据(如果异常):" + future.get());
可以感知的方式（无返回值）：
CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {
System.out.println("线程1Id:" + Thread.currentThread().getId());
int i = 100 / 2;
System.out.println("线程1运行结果:" + i);
return i;
}, executorService).thenAcceptAsync((result)->{
System.out.println("线程2ID:"+Thread.currentThread().getId());//没有返回值可以返回void
int j = result/2;
System.out.println("线程2运行结果:"+j);
},executorService);
System.out.println("修正数据(如果异常):" + future.get());
可以感知的方式（有返回值）：
注意这个get是阻塞的。
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
System.out.println("线程1Id:" + Thread.currentThread().getId());
int i = 100 / 2;
System.out.println("线程1运行结果:" + i);
return i;
}, executorService).thenApplyAsync((result)->{
System.out.println("线程2ID:"+Thread.currentThread().getId());//没有返回值可以返回void
int j = result/2;
System.out.println("线程2运行结果:"+j);
return j;
},executorService);
System.out.println("修正数据(如果异常):" + future.get());
两任务组合，都要完成才执行第三
CompletableFuture<Integer> future01 = CompletableFuture.supplyAsync(() -> {
System.out.println("线程1Id:" + Thread.currentThread().getId());
int i = 100 / 2;
System.out.println("线程1运行结果:" + i);
return i;
}, executorService);
CompletableFuture<Integer> future02 = CompletableFuture.supplyAsync(() -> {
System.out.println("线程2Id:" + Thread.currentThread().getId());
int i = 100 / 2;
System.out.println("线程2运行结果:" + i);
return i;
}, executorService);
// //无法感知结果
// future01.runAfterBothAsync(future02,()->{
// System.out.println("线程3Id:" + Thread.currentThread().getId());
// },executorService);
//感知结果无返回值
// future01.thenAcceptBothAsync(future02, (f1, f2) -> {
// System.out.println("线程3Id:" + Thread.currentThread().getId());
// System.out.println("线程3运行结果:" + (f1 + f2));
// }, executorService);
//感知结果带返回值
CompletableFuture<Integer> future = future01.thenCombineAsync(future02, (f1, f2) -> {
System.out.println("线程3Id:" + Thread.currentThread().getId());
System.out.println("线程3运行结果:" + (f1 + f2));
return f1 + f2;
}, executorService);
System.out.println("修正数据(如果异常):" + future.get());
两任务组合，随便一个完成就执行第三
CompletableFuture<Integer> future01 = CompletableFuture.supplyAsync(() -> {
System.out.println("线程1Id:" + Thread.currentThread().getId());
int i = 100 / 2;
System.out.println("线程1运行结果:" + i);
return i;
}, executorService);
CompletableFuture<Integer> future02 = CompletableFuture.supplyAsync(() -> {
System.out.println("线程2Id:" + Thread.currentThread().getId());
int i = 100 / 2;
try {
Thread.sleep(3000);//必须睡完再执行些东西，否则跟没睡一样！
System.out.println("线程2运行结果:" + i);
} catch (InterruptedException e) {
e.printStackTrace();
}
return i;
}, executorService);
//只要有一个完成就执行任务3，不感知结果，无返回值
// future01.runAfterEitherAsync(future02, () -> {
// System.out.println("线程3Id:" + Thread.currentThread().getId());
// }, executorService);
//只要有一个完成就执行任务3，感知结果，无返回值
// future01.acceptEitherAsync(future02, (result) -> {
// System.out.println("线程3Id:" + Thread.currentThread().getId());
// System.out.println("线程3运行结果:" + result);
// }, executorService);
//只要有一个完成就执行任务3，感知结果，有返回值
CompletableFuture<Integer> future = future01.applyToEitherAsync(future02, (result) -> {
System.out.println("线程3Id:" + Thread.currentThread().getId());
System.out.println("线程3运行结果:" + result);
return result;
}, executorService);
System.out.println("修正数据(如果异常):" + future.get());
多任务组合
CompletableFuture<String> futureImg = CompletableFuture.supplyAsync(() -> {
System.out.println("商品图片信息");
return "hello.jpg";
}, executorService);
CompletableFuture<String> futureAttr= CompletableFuture.supplyAsync(() -> {
System.out.println("商品属性信息");
return "黑色+256G";
}, executorService);
CompletableFuture<String> futureDesc = CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(3000);
System.out.println("商品介绍信息");
} catch (InterruptedException e) {
e.printStackTrace();
}
return "小米手机";
}, executorService);
//多任务组合，必须完成
CompletableFuture<Void> allOf = CompletableFuture.allOf(futureImg, futureAttr, futureDesc);
allOf.get();//等待所有结果完成，这个get会把main阻塞，没get就与main独立
System.out.println("修正数据(如果异常):" + futureImg.get()+","+futureAttr.get()+","+futureDesc.get());
//只要有一个成功。这个带有返回值！
CompletableFuture<Object> anyOf = CompletableFuture.anyOf(futureImg, futureAttr, futureDesc);
System.out.println("修正数据(如果异常):" + anyOf.get());
项目使用异步编排
配置类。注意@Primary为了解决同名Bean
@ConfigurationProperties(prefix = "gulimall.thread")
@Component
@Primary
@Data
public class ThreadPoolConfigProperties {
private Integer coreSize;
private Integer maxSize;
private Integer keepAliveTime;
}
@Configuration
@EnableConfigurationProperties(ThreadPoolConfigProperties.class)
public class MyThreadConfig {
@Bean
public ThreadPoolExecutor threadPoolExecutor(ThreadPoolConfigProperties pool){
return new ThreadPoolExecutor(
pool.getCoreSize(),//核心大小
pool.getMaxSize(),//最大大小
pool.getKeepAliveTime(),
TimeUnit.SECONDS,
new LinkedBlockingDeque<>(100000),//最多10w个阻塞任务
Executors.defaultThreadFactory(),//默认工程
new ThreadPoolExecutor.AbortPolicy()//抛弃策略
);
}
}
使用：
@Override
public SkuItemVo getItem(Long skuId) throws ExecutionException, InterruptedException {
SkuItemVo skuItemVo = new SkuItemVo();
//第一个异步任务
CompletableFuture<SkuInfoEntity> infoFuture = CompletableFuture.supplyAsync(() -> {
//1. sku的基本信息 pms_sku_info
SkuInfoEntity skuInfoEntity = this.getById(skuId);
skuItemVo.setInfo(skuInfoEntity);
return skuInfoEntity;
}, threadPoolExecutor);
//345都需要1完成后拿到spuid执行。345是并列同时执行的
CompletableFuture<Void> saleAttrFuture = infoFuture.thenAcceptAsync((result) -> {
//3. 获取的是spu的销售属性组合
List<SkuItemSaleAttrVo> saleAttrVos = skuSaleAttrValueService.getSaleAttrsBySpuId(result.getSpuId());
skuItemVo.setSaleAttr(saleAttrVos);
}, threadPoolExecutor);
CompletableFuture<Void> descFuture = infoFuture.thenAcceptAsync((result) -> {
//4. 获取spu的介绍
SpuInfoDescEntity spuInfoDesc = descService.getById(result.getSkuId());
skuItemVo.setDesc(spuInfoDesc);
}, threadPoolExecutor);
CompletableFuture<Void> baseAttrFuture = infoFuture.thenAcceptAsync((result) -> {
//5. 获取spu的规格参数信息
List<SpuItemAttrGroupVo> attrGroupVos = attrGroupService.getAttrGroupWithAttrsBySpuId(result.getSpuId(), result.getCatalogId());
skuItemVo.setGroupAttrs(attrGroupVos);
}, threadPoolExecutor);
//第二个异步任务
CompletableFuture<Void> imagesFuture = CompletableFuture.runAsync(() -> {
//2. sku的图片信息 pms_sku_images
List<SkuImagesEntity> images = imagesService.getImagesBySkuId(skuId);
skuItemVo.setImages(images);
}, threadPoolExecutor);
//等待所有任务完成才能返回结果，既当前Thread是阻塞的
CompletableFuture.allOf(saleAttrFuture,descFuture,baseAttrFuture,imagesFuture).get();
return skuItemVo;
}