多线程之CompletableFuture全方面解析
多线程之CompletableFuture全方面解析
目录:
前言:
在我们写的一个底层Api
中,由于上亿级数据量情况下,查询效率较慢,本篇文档记录一下优化过程所用技术栈CompletableFuture
的具体使用方法。整体优化思路在并发大数据量情况下如下:
有事务:因为有事务影响,所以使用多线程可能会对先改后查这种情况的数据准确性无法进行保证,所以有以下几种情况(表大概50个字段):
select * from user a where a.id in(......)
select * from user a where (a.id in(......)) or (a.id in(......))
SELECT * FROM user where a.id in (...) UNION ALL SELECT * FROM user where a.id in (...)
具体测试图就不贴了,因为不是重点,在50万数据存量十并发下一次性查2万数据的十个字段 or in 是最快的 整体执行(加上业务逻辑)下来不到3.5s。
无事务:采用多线程,条件和上面的一样执行下来0.7s,一开始自己想的就是根据数据量使用线程池每1000条创建一个线程(new Thread的方式),后来发现写起来怪麻烦的,经过部门大佬指点发现有一种写法很简单,使用
CompletableFuture
进行多线程的处理,这也是今天想要总结的重点!!!!!!!!!
最佳线程数:
在说CompletableFuture
之前,我想先大概说一下最佳线程数这个,因为创建线程和销毁线程都是比较耗时的操作,频繁的创建和销毁线程会浪费很多CPU的资源。此外,如果每个任务都创建一个线程去处理,这样线程会越来越多。我们知道每个线程默认情况下占1M的内存空间,如果线程非常多,内存资源将会被耗尽。这时,我们需要线程池去管理线程,不会出现内存资源被耗尽的情况,也不会出现频繁创建和销毁线程的情况,因为它内部是可以复用线程的。
那么 我们怎么样去确定最佳线程数呢?(后面会有公式滴~先看基本)
我们在使用spring cloud时,通常会使用ThreadPoolExecutor
去设置线程池的参数,那我们就先总结一下ThreadPoolExecutor
:
一、ThreadPoolExecutor
的重要参数
corePoolSize
:核心线程数核心线程会一直存活,及时没有任务需要执行
当线程数小于核心线程数时,即使有线程空闲,线程池也会优先创建新线程处理
设置
allowCoreThreadTimeout
=true(默认false)时,核心线程会超时关闭
queueCapacity
:任务队列容量(阻塞队列)- 当核心线程数达到最大时,新任务会放在队列中排队等待执行
maxPoolSize
:最大线程数当线程数>=
corePoolSize
,且任务队列已满时。线程池会创建新线程来处理任务当线程数=
maxPoolSize
,且任务队列已满时,线程池会拒绝处理任务而抛出异常
keepAliveTime
:线程空闲时间当线程空闲时间达到
keepAliveTime
时,线程会退出,直到线程数量等于corePoolSize
如果
allowCoreThreadTimeout
=true,则会直到线程数量=0
allowCoreThreadTimeout
:允许核心线程超时rejectedExecutionHandler
:任务拒绝处理器两种情况会拒绝处理任务:
- 当线程数已经达到
maxPoolSize
,切队列已满,会拒绝新任务 - 当线程池被调用shutdown()后,会等待线程池里的任务执行完毕,再shutdown。如果在调用shutdown()和线程池真正shutdown之间提交任务,会拒绝新任务
- 当线程数已经达到
线程池会调用
rejectedExecutionHandler
来处理这个任务。如果没有设置默认是AbortPolicy
,会抛出异常ThreadPoolExecutor
类有几个内部实现类来处理这类情况:AbortPolicy
丢弃任务,抛运行时异常CallerRunsPolicy
执行任务DiscardPolicy
忽视,什么都不会发生DiscardOldestPolicy
从队列中踢出最先进入队列(最后一个执行)的任务
实现
RejectedExecutionHandler
接口,可自定义处理器
二、ThreadPoolExecutor
执行顺序:
线程池按以下行为执行任务
- 当线程数小于核心线程数时,创建线程。
- 当线程数大于等于核心线程数,且任务队列未满时,将任务放入任务队列。
- 当线程数大于等于核心线程数,且任务队列已满
- 若线程数小于最大线程数,创建线程
- 若线程数等于最大线程数,抛出异常,拒绝任务
三、如何设置参数
默认值
- corePoolSize=1 - queueCapacity=Integer.MAX_VALUE - maxPoolSize=Integer.MAX_VALUE - keepAliveTime=60s - allowCoreThreadTimeout=false - rejectedExecutionHandler=AbortPolicy()
如何来设置
- 需要根据几个值来决定
tasks
:每秒的任务数,假设为500~1000taskcost
:每个任务花费时间,假设为0.1sresponsetime
:系统允许容忍的最大响应时间,假设为1s
- 做几个计算
corePoolSize
= 每秒需要多少个线程处理?threadcount = tasks/(1/taskcost) =tasks*taskcost= (500~1000)*0.1 = 50~100
个线程。corePoolSize
设置应该大于50- 根据8020原则,如果80%的每秒任务数小于800,那么
corePoolSize
设置为80即可
queueCapacity = (coreSizePool/taskcost)*responsetime
- 计算可得
queueCapacity
= 80/0.1*1 = 80。意思是队列里的线程可以等待1s,超过了的需要新开线程来执行 - 切记不能设置为
Integer.MAX_VALUE
,这样队列会很大,线程数只会保持在corePoolSize
大小,当任务陡增时,不能新开线程来执行,响应时间会随之陡增。
- 计算可得
maxPoolSize = (max(tasks)- queueCapacity)/(1/taskcost)
- 计算可得
maxPoolSize
= (1000-80)/10 = 92 - (最大任务数-队列容量)/每个线程每秒处理能力 = 最大线程数
- 计算可得
rejectedExecutionHandler
:根据具体情况来决定,任务不重要可丢弃,任务重要则要利用一些缓冲机制来处理keepAliveTime
和allowCoreThreadTimeout
采用默认通常能满足
以上都是理想值,实际情况下要根据机器性能来决定。如果在未达到最大线程数的情况机器
cpu load
已经满了,则需要通过升级硬件(呵呵)和优化代码,降低taskcost
来处理。
举个栗子:
Future
:
因为在CompletableFuture
之前我们一直用的是Future来实现异步操作,并且CompletableFuture
实现了Future的接口,我们先浅看一下Future:
Future提供了一种异步并行计算的功能,如果主线程需要执行一个很耗时的计算任务,我们可以通过future把这个任务放在异步线程去执行,主线程则去执行其他任务,处理完后,再用Future获取结果。
举个栗子:
假设我们有两个任务服务,一个查询用户基本信息,一个查询用户住宅信息。
public class UserInfoService {public UserInfo getUserInfo(Long userId) throws InterruptedException {Thread.sleep(300);//模拟调用耗时return new UserInfo("666", "伊利蛋", 27); //一般是查数据库,或者远程调用返回的}
}public class HouseService {public HouseInfo getHouseInfo(long userId) throws InterruptedException {Thread.sleep(500); //模拟调用耗时return new HouseInfo("666", "艾泽拉拉小区");}
}
接下来,我们来演示下,在主线程中是如何使用Future来进行异步调用的。
public class FutureTest {public static void main(String[] args) throws ExecutionException, InterruptedException {ExecutorService executorService = Executors.newFixedThreadPool(10);UserInfoService userInfoService = new UserInfoService();HouseService houseService = new HouseService();long userId =666L;long startTime = System.currentTimeMillis();//调用用户服务获取用户基本信息FutureTask<UserInfo> userInfoFutureTask = new FutureTask<>(new Callable<UserInfo>() {@Overridepublic UserInfo call() throws Exception {return userInfoService.getUserInfo(userId);}});executorService.submit(userInfoFutureTask);Thread.sleep(300); //模拟主线程其它操作耗时FutureTask<HouseInfo> houseInfoFutureTask = new FutureTask<>(new Callable<HouseInfo>() {@Overridepublic HouseInfo call() throws Exception {return houseService.getHouseInfo(userId);}});executorService.submit(houseInfoFutureTask);UserInfo userInfo = userInfoFutureTask.get();//获取个人信息结果HouseInfo houseInfo = houseInfoFutureTask.get();//获取住宅信息结果System.out.println("总共用时" + (System.currentTimeMillis() - startTime) + "ms");}
}-------------------------------------------------------------------------
运行结果 : 总共用时806ms
如果我们不使用Future进行异步调用,而是在主线程中串行进行的话,耗时大概为1100ms,所以future对程序执行效率提升效果还是可以的。
深入看一下future对结果的获取,发现它对于结果的获取并不是很友好,只能通过阻塞或者轮询的方式得到任务的结果(源码可以搜一哈,网上很多):
- Future.get() 就是阻塞调用,在线程获取结果之前get方法会一直阻塞。
- Future提供了一个isDone方法,可以在程序中轮询这个方法查询执行结果。
这个时候就发现问题了,阻塞的这种方式和我们异步编程的设计理念不一样啊,难搞,轮询的话,又会浪费无谓的CPU资源,那就没有一种更好的方式么???当然我都能发现,大佬那么多,人家早都发现了,在JDK8
的时候推出了,也就是我们本次要总结的重点CompletableFuture
,为什么他就能解决呢?
因为CompletableFuture
提供了一种观察者模式类似的机制,可以让任务执行完成后通知监听的一方。
CompletableFuture
:
首先我们还是用刚才future那个栗子,不过这次选择CompletableFuture
来进行实现:
public class FutureTest {public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {UserInfoService userInfoService = new UserInfoService();HouseService houseService = new HouseService();long userId =666L;long startTime = System.currentTimeMillis();//调用用户服务获取用户基本信息CompletableFuture<UserInfo> completableUserInfoFuture = CompletableFuture.supplyAsync(() -> userInfoService.getUserInfo(userId));CompletableFuture<HouseInfo> completableHouseInfoFuture = CompletableFuture.supplyAsync(() -> houseService.getHouseInfo(userId)); Thread.sleep(300); //模拟主线程其它操作耗时UserInfo userInfo = completableUserInfoFuture.get(2,TimeUnit.SECONDS);//获取个人信息结果HouseInfo houseInfo = completableHouseInfoFuture.get();//获取住宅信息结果System.out.println("总共用时" + (System.currentTimeMillis() - startTime) + "ms");}
} -------------------------------------------------------------------------
运行结果 : 总共用时800ms
可以发现,使用CompletableFuture
,代码确实简洁了很多。CompletableFuture
的supplyAsync
方法,提供了异步执行的功能,线程池也不用单独创建了。
接下来我们可以一起总结一下CompletableFuture
的具体使用。
CompletableFuture
的三个使用场景:
- 创建异步任务
- 简单任务异步回调
- 多任务组合处理
创建异步任务:
CompletableFuture
创建异步任务,一般有supplyAsync
和runAsync
两个方法:
supplyAsync
执行CompletableFuture
任务,支持返回值。runAsync
执行CompletableFuture
任务,没有返回值。
supplyAsync
方法:
//使用默认内置线程池ForkJoinPool.commonPool(),根据supplier构建执行任务
public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier)
//自定义线程,根据supplier构建执行任务
public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor)
runAsync
方法:
//使用默认内置线程池ForkJoinPool.commonPool(),根据runnable构建执行任务
public static CompletableFuture<Void> runAsync(Runnable runnable)
//自定义线程,根据runnable构建执行任务
public static CompletableFuture<Void> runAsync(Runnable runnable, Executor executor)
举个栗子:
public class FutureTest {public static void main(String[] args) {//可以自定义线程池ExecutorService executor = Executors.newCachedThreadPool();//runAsync的使用CompletableFuture<Void> runFuture = CompletableFuture.runAsync(() -> System.out.println("runAsync,为了部落"), executor);//supplyAsync的使用CompletableFuture<String> supplyFuture = CompletableFuture.supplyAsync(() -> {System.out.print("supplyAsync,为了联盟");return "哈哈哈哈哈"; }, executor);//runAsync的future没有返回值,输出nullSystem.out.println(runFuture.join());//supplyAsync的future,有返回值System.out.println(supplyFuture.join());executor.shutdown(); // 线程池需要关闭}
}
-------------------------------------------------------------------------
//输出
runAsync,为了部落
null
supplyAsync,为了联盟哈哈哈哈哈
任务异步回调:
任务异步回调大概有六种使用场景:
1.thenRun/thenRunAsync
public CompletableFuture<Void> thenRun(Runnable action);
public CompletableFuture<Void> thenRunAsync(Runnable action);
CompletableFuture
的thenRun
方法,通俗点讲就是,做完第一个任务后,再做第二个任务。某个任务执行完成后,执行回调方法;但是前后两个任务没有参数传递,第二个任务也没有返回值,举个例子:
public class FutureThenRunTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> orgFuture = CompletableFuture.supplyAsync(()->{System.out.println("先打BOSS");return "为了圣光";});CompletableFuture thenRunFuture = orgFuture.thenRun(() -> {System.out.println("再领奖励");});System.out.println(thenRunFuture.get());}
}
//输出
先打BOSS
再领奖励
null
咱们可以通过源码看看thenRun
和thenRunAsync
的区别:
(嘀嘀嘀:后面介绍的thenAccept
和thenAcceptAsync
,thenApply
和thenApplyAsync
等区别和这个相同)
private static final Executor asyncPool = useCommonPool ?ForkJoinPool.commonPool() : new ThreadPerTaskExecutor();public CompletableFuture<Void> thenRun(Runnable action) {return uniRunStage(null, action);}public CompletableFuture<Void> thenRunAsync(Runnable action) {return uniRunStage(asyncPool, action);}
如果你执行第一个任务的时候,传入了一个自定义线程池:
- 调用
thenRun
方法执行第二个任务时,则第二个任务和第一个任务是共用同一个线程池。 - 调用
thenRunAsync
执行第二个任务时,则第一个任务使用的是你自己传入的线程池,第二个任务使用的是ForkJoin
线程池。
2.thenAccept/thenAcceptAsync
CompletableFuture
的thenAccept
方法表示,第一个任务执行完成后,执行第二个回调方法任务,会将该任务的执行结果,作为入参,传递到回调方法中,但是回调方法是没有返回值的。
public class FutureThenAcceptTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> orgFuture = CompletableFuture.supplyAsync(()->{System.out.println("第一个CompletableFuture方法任务");return "为了圣光";});CompletableFuture thenAcceptFuture = orgFuture.thenAccept((a) -> {if ("为了圣光".equals(a)) {System.out.println("牛的");}System.out.println("oops");});System.out.println(thenAcceptFuture.get());}
}
//输出
第一个CompletableFuture方法任务
牛的
oops
null
3.thenApply/thenApplyAsync
CompletableFuture
的thenApply
方法表示,第一个任务执行完成后,执行第二个回调方法任务,会将该任务的执行结果,作为入参,传递到回调方法中,并且回调方法是有返回值的。
public class FutureThenApplyTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> orgFuture = CompletableFuture.supplyAsync(()->{System.out.println("第一个CompletableFuture方法任务");return "为了圣光";});CompletableFuture<String> thenApplyFuture = orgFuture.thenApply((a) -> {if ("为了圣光".equals(a)) {return "oops";}return "先考虑考虑";});System.out.println(thenApplyFuture.get());}
}
//输出
第一个CompletableFuture方法任务
oops
4.exceptionally
CompletableFuture
的exceptionally
方法表示,某个任务执行异常时,执行的回调方法;并且有抛出异常作为参数,传递到回调方法。
public class FutureExceptionTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> orgFuture = CompletableFuture.supplyAsync(()->{System.out.println("当前线程名称:" + Thread.currentThread().getName());throw new RuntimeException();});CompletableFuture<String> exceptionFuture = orgFuture.exceptionally((e) -> {e.printStackTrace();return "歪歪歪?你的程序异常啦";});System.out.println(exceptionFuture.get());}
}
//输出
当前线程名称:ForkJoinPool.commonPool-worker-1
java.util.concurrent.CompletionException: java.lang.RuntimeExceptionat java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1592)at java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1582)at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
Caused by: java.lang.RuntimeExceptionat cn.eovie.future.FutureWhenTest.lambda$main$0(FutureWhenTest.java:13)at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)... 5 more
歪歪歪?你的程序异常啦"
5.whenComplete
方法
CompletableFuture
的whenComplete
方法表示,某个任务执行完成后,执行的回调方法,无返回值;并且whenComplete
方法返回的CompletableFuture
的result是上个任务的结果。
public class FutureWhenTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> orgFuture = CompletableFuture.supplyAsync(()->{System.out.println("当前线程名称:" + Thread.currentThread().getName());try {Thread.sleep(2000L);} catch (InterruptedException e) {e.printStackTrace();}return "小陈";});CompletableFuture<String> rstFuture = orgFuture.whenComplete((a, throwable) -> {System.out.println("当前线程名称:" + Thread.currentThread().getName());System.out.println("上个任务执行完啦,还把" + a + "传过来");if ("小陈".equals(a)) {System.out.println("666");}System.out.println("233333");});System.out.println(rstFuture.get());}
}
//输出
当前线程名称:ForkJoinPool.commonPool-worker-1
当前线程名称:ForkJoinPool.commonPool-worker-1
上个任务执行完啦,还把小陈传过来
666
233333
小陈
6.handle
CompletableFuture
的handle
方法表示,某个任务执行完成后,执行回调方法,并且是有返回值的;并且handle
方法返回的CompletableFuture
的result是回调方法执行的结果。
public class FutureHandlerTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> orgFuture = CompletableFuture.supplyAsync(()->{System.out.println("当前线程名称:" + Thread.currentThread().getName());try {Thread.sleep(2000L);} catch (InterruptedException e) {e.printStackTrace();}return "小陈";});CompletableFuture<String> rstFuture = orgFuture.handle((a, throwable) -> {System.out.println("上个任务执行完啦,还把" + 小陈 + "传过来");if ("小陈".equals(a)) {System.out.println("666");return "为了圣光";}System.out.println("233333");return null;});System.out.println(rstFuture.get());}
}
//输出
当前线程名称:ForkJoinPool.commonPool-worker-1
上个任务执行完啦,还把小陈传过来
666
为了圣光
多个任务组合处理:
AND
组合关系:
thenCombine
/ thenAcceptBoth
/ runAfterBoth
都表示:将两个CompletableFuture
组合起来,只有这两个都正常执行完了,才会执行某个任务。
区别在于:
thenCombine
:会将两个任务的执行结果作为方法入参,传递到指定方法中,且有返回值thenAcceptBoth
: 会将两个任务的执行结果作为方法入参,传递到指定方法中,且无返回值runAfterBoth
:不会把执行结果当做方法入参,且没有返回值。
public class ThenCombineTest {public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {CompletableFuture<String> first = CompletableFuture.completedFuture("第一个异步任务");ExecutorService executor = Executors.newFixedThreadPool(10);CompletableFuture<String> future = CompletableFuture//第二个异步任务.supplyAsync(() -> "第二个异步任务", executor)// (w, s) -> System.out.println(s) 是第三个任务.thenCombineAsync(first, (s, w) -> {System.out.println(w);System.out.println(s);return "两个任务都执行完才会输出";}, executor);System.out.println(future.join());executor.shutdown();}
}
//输出
第一个异步任务
第二个异步任务
两个任务都执行完才会输出
OR
组合的关系:
applyToEither
/ acceptEither
/ runAfterEither
都表示:将两个CompletableFuture
组合起来,只要其中一个执行完了,就会执行某个任务。
区别在于:
applyToEither
:会将已经执行完成的任务,作为方法入参,传递到指定方法中,且有返回值acceptEither
: 会将已经执行完成的任务,作为方法入参,传递到指定方法中,且无返回值runAfterEither
: 不会把执行结果当做方法入参,且没有返回值。
public class AcceptEitherTest {public static void main(String[] args) {//第一个异步任务,休眠2秒,保证它执行晚点CompletableFuture<String> first = CompletableFuture.supplyAsync(()->{try{Thread.sleep(2000L);System.out.println("执行完第一个异步任务");}catch (Exception e){return "第一个任务异常";}return "第一个异步任务";});ExecutorService executor = Executors.newSingleThreadExecutor();CompletableFuture<Void> future = CompletableFuture//第二个异步任务.supplyAsync(() -> {System.out.println("执行完第二个任务");return "第一个任务还在睡觉,这是第二个任务";}, executor)//第三个任务.acceptEitherAsync(first, System.out::println, executor);executor.shutdown();}
}
//输出
执行完第二个任务
第一个任务还在睡觉,这是第二个任务
AllOf
:
所有任务都执行完成后,才执行 allOf
返回的CompletableFuture
。如果任意一个任务异常,allOf
的CompletableFuture
,执行get方法,会抛出异常
public class allOfFutureTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<Void> a = CompletableFuture.runAsync(()->{System.out.println("我执行完了");});CompletableFuture<Void> b = CompletableFuture.runAsync(() -> {System.out.println("我也执行完了");});CompletableFuture<Void> allOfFuture = CompletableFuture.allOf(a, b).whenComplete((m,k)->{System.out.println("finish");});}
}
//输出
我执行完了
我也执行完了
finish
AnyOf
:
任意一个任务执行完,就执行anyOf
返回的CompletableFuture
。如果执行的任务异常,anyOf
的CompletableFuture
,执行get方法,会抛出异常
public class AnyOfFutureTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<Void> a = CompletableFuture.runAsync(()->{try {Thread.sleep(3000L);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("我执行完了");});CompletableFuture<Void> b = CompletableFuture.runAsync(() -> {System.out.println("我也执行完了");});CompletableFuture<Object> anyOfFuture = CompletableFuture.anyOf(a, b).whenComplete((m,k)->{System.out.println("finish");
// return "捡田螺的小男孩";});anyOfFuture.join();}
}
//输出
我也执行完了
finish
thenCompose
:
thenCompose
方法会在某个任务执行完成后,将该任务的执行结果,作为方法入参,去执行指定的方法。该方法会返回一个新的CompletableFuture
实例
- 如果该
CompletableFuture
实例的result
不为null
,则返回一个基于该result
新的CompletableFuture
实例; - 如果该
CompletableFuture
实例为null
,然后就执行这个新任务
public class ThenComposeTest {public static void main(String[] args) throws ExecutionException, InterruptedException {CompletableFuture<String> f = CompletableFuture.completedFuture("第一个任务");//第二个异步任务ExecutorService executor = Executors.newSingleThreadExecutor();CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "第二个任务", executor).thenComposeAsync(data -> {System.out.println(data); return f; //使用第一个任务作为返回}, executor);System.out.println(future.join());executor.shutdown();}
}
//输出
第二个任务
第一个任务
本文部分内容参考公众号 捡田螺的小男孩
谢谢大佬的资料
多线程之CompletableFuture全方面解析相关推荐
- Android多线程之ArrayBlockingQueue源码解析
阻塞队列系列 Android多线程之LinkedBlockingQueue源码解析 Android多线程之SynchronousQueue源码解析 Andorid多线程之DelayQueue源码分析 ...
- Android多线程之IntentService源码解析
想要了解 IntentService 的工作原理需要先对 Android 系统中以 Handler.Looper.MessageQueue 组成的异步消息处理机制以及 HandlerThread 有所 ...
- 多线程之CompletableFuture和ParallelStream应该使用哪个?
多线程之CompletableFuture和ParallelStream应该使用哪个 简介 实例场景 测试代码 开始测试 总结 备注 简介 随着用户对性能和体验的要求越来越高,异步在项目中用的也就越来 ...
- android handlerthread 线程管理,Android多线程之HandlerThread源码解析
一.概述 先来了解一下HandlerThread的几个特性 HandlerThread继续于Thread,本身就是一个线程类 HandlerThread在内部维护了自己的Looper对象,所以可以进行 ...
- Java多线程之CAS深入解析
Java多线程之CAS深入解析 目录: CAS是什么 CAS底层原理Unsafe深入解析 CAS缺点 引子:蚂蚁花呗一面:讲一讲AtomicInteger,为什么要用CAS而不是synchronize ...
- Java多线程之8Lock问题解析
Java多线程之8Lock问题解析 本文目录 1. 8Lock实例: 标准访问的时候,请问先打印邮件还是短信? sendEmail方法暂停4秒钟,请问先打印邮件还是短信? 新增Hello普通方法,请问 ...
- 基于神策用户画像,在线教育企业线索标签体系搭建及培育全流程解析
作者介绍:TigerHu,环球网校大数据营销产品 leader,主导数据产品线和营销 CRM 产品线. 本文内容均从作者真实实践过程出发,结合作者公司与神策数据合作真实场景,从神策用户画像产品出发,全 ...
- linux 线程pthread_detach,linux线程之pthread_join和pthread_detach
在任何一个时间点上,线程是可结合的(joinable)或者是分离的(detached).一个可结合的线程能够被其他线程收回其资源和杀死.在 被其他线程回收之前,它的存储器资源(例如栈)是不释放的.相反 ...
- 多线程之NSThread
关于多线程会有一系列如下: 多线程之概念解析 多线程之pthread, NSThread, NSOperation, GCD 多线程之NSThread 多线程之NSOperation 多线程之GCD ...
最新文章
- Apache IoTDB v0.12.5 发布!
- table row设置cell的html,css中display设置为table、table-row、table-cell后的作用及其注意点...
- 如何快速找到settype被assign的product category
- 获取 metadata 过程详解 - 每天5分钟玩转 OpenStack(167)
- 关于css 的AST 语法树的理解
- 转jmeter 性能测试 JDBC Request (查询数据库获取数据库数据) 的使用
- C语言:运算符,表达式与语句
- java aop管理权限_基于spring aop 权限管理系统原型 - andyj2ee - BlogJava
- 如何用70行Java代码实现神经网络算法
- 计算机班英语试卷考法,计算机专业英语期末考试试卷A
- Android 5.0特性
- 绘制附带 AHT20 温湿度传感器的 stm32 电路原理图
- c 语言文件加密程序,怎么用c语言编写程序给文件夹加密
- access里的多步oledb错误_access数据库常见问题处理
- Booting kernel failed
- element ui表格标题及内容居中
- ubuntu16.04安装tensorflow,pytorch,gluon等
- 【网络教程】设置远程开启,主板如何开启网络唤醒,华硕主板网络唤醒 WOL 的设置与实现!
- 上证指数开盘指数预测 Matlab
- 播放数万 | 一文学会Cytoscape网络图绘制 - 最新教程
热门文章
- 一桐对第三方SEO博客的一点拙见
- MSYS2 瘦身小攻略
- IT教育培训机构套路揭秘,这样的学校不能选,擦亮眼睛不上当
- 百度收录链接如何查询
- 传智播客-刘意-java深入浅出精华版学习笔记Day05
- 零基础学 MySQL
- 卡巴斯基互联网安全套装(kis 官方
- Unknown symbol crc32c
- python画正方形的代码_python画正方形的代码是什么?
- node-redis:ErrorReply: ERR wrong number of arguments for ‘auth‘ command