ThreadPoolExecutor中addWorker，continue retry和break retry是什么意思

今天看ThreadPoolExecutor的代码，其中有一个addWorker的函数，里面有个retry的标签，从来没遇到过这种用法。来深入探究一下。

先看一下addWorker的代码。

private boolean addWorker(Runnable firstTask, boolean core) {retry:for (;;) {int c = ctl.get();int rs = runStateOf(c);// Check if queue empty only if necessary.if (rs >= SHUTDOWN &&! (rs == SHUTDOWN &&firstTask == null &&! workQueue.isEmpty()))return false;for (;;) {int wc = workerCountOf(c);if (wc >= CAPACITY ||wc >= (core ? corePoolSize : maximumPoolSize))return false;if (compareAndIncrementWorkerCount(c))break retry;c = ctl.get();  // Re-read ctlif (runStateOf(c) != rs)continue retry;// else CAS failed due to workerCount change; retry inner loop}}
...
}

我们先来猜测一下，retry不是java中的关键字，这应该类似标签的一种写法，看起来有点像goto；break retry可能是跳出到retry标签处(继续执行retry标签下的循环，保留最外层循环的变量临时值)，continue retry直接跳出标签(不管标签中有几层循环)，继续执行其他代码。实际是不是这样呢？

show me the demo code！

public class RetryDemo {public static void main(String[] args) {int count = 0;retry:for (int i=0; i<3; i++) {for (int j=0; j<5; j++) {count++;if (count == 4) {continue retry;}System.out.print(count + " ");}}}
}输出结果：
1 2 3 5 6 7 8 9 10 11 12 13 14public class RetryDemo {public static void main(String[] args) {int count = 0;retry:for (int i=0; i<3; i++) {for (int j=0; j<5; j++) {count++;if (count == 4) {break retry;}System.out.print(count + " ");}}}
}输出结果：
1 2 3

聪明的你，看明白为什么输出会是这样么？

再来解释一遍， break label直接跳出到标签处，不再执行循环代码；continue label，只是结束本轮循环，跳转到标签处，继续下一轮循环（本质上与单层循环的break和continue类似）。

写到这里，那提个问题，如果是三层for循环的标签，输出结果是什么呢？

public class RetryDemo {public static void main(String[] args) {int count = 0;retry:for (int i=0; i<3; i++) {for (int k=0; k<2; k++) {for (int j = 0; j < 5; j++) {count++;if (count == 4) {continue retry;}System.out.print(count + " ");}}}}
}输出结果
1 2 3 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24public class RetryDemo {public static void main(String[] args) {int count = 0;retry:for (int i=0; i<3; i++) {for (int k=0; k<2; k++) {for (int j = 0; j < 5; j++) {count++;if (count == 4) {break retry;}System.out.print(count + " ");}}}}
}
输出结果
1 2 3

可以发现，break retry输出的结果仍是1 2 3，continue retry，只是提前结束了一轮的循环，下一轮循环仍然会继续。大师把代码写成这样是经典，我们就不建议把代码写成这样了，可读性太差。

那addWorker这段代码到底什么意思呢？大师是用CAS无锁的方式，增加线程数，因为是CAS无锁，那就有可能增加线程数失败，此时continue 到retry标签处重试，重新尝试CAS无锁的方式增加线程数；haha，如果运气比较好，直接增加线程数成功，那就bread retry好了，继续执行其他逻辑代码。

你真的懂了么？最好把demo代码复制下来本机调试一下！欢迎留言沟通！

ThreadPoolExecutor中addWorker，continue retry和break retry是什么意思相关推荐

java聊天室小程序论文_在Java项目中利用continue与break制作一个聊天室小程序
在Java项目中利用continue与break制作一个聊天室小程序发布时间:2020-12-08 16:03:27 来源:亿速云阅读:98 作者:Leah 在Java项目中利用continue与 ...
python中break和continue区别_Shell break和continue跳出循环详解
使用 while.until.for.select 循环时,如果想提前结束循环(在不满足结束条件的情况下结束循环),可以使用 break 或者 continue 关键字. 在C语言.C++.C#.Py ...
[转]在jQuery的each()函数中使用continue和break
jQuery的each函数可调用选择器得到的元素集进行循环调用.这意味着,每次执行传递进来的函数时,函数中的this关键字都指向一个不同的 DOM元素(每次都是一个不同的匹配元素).而且,在每次执行函 ...
Matlab中的continue、break和return语句
Continue: 经常用在for和while语句中,continue一旦被执行,就会终止当前循环,进行下一次循环. eg, 在for 循环中: clc clear all close alli = ...
python中的continue和break
python中的continue和break 1.comntinue只会跳出当次循环代码: count=0 while count<100:print("loop",cou ...
循环和switch语句中的continue、break
原文:https://www.cnblogs.com/lkprof/p/3475423.html 1. 在switch语句中,"case 常量表达式"只相当于一个语句标号, 表达式 ...
switch中使用continue和break
如果你在switch中使用continue,continue生效是对于while循环如果你在switch中使用break,break生效是对于switch. 如果在switch外使用continue ...
【笔记】python的while循环简介：使用while循环、让用户选择何时退出、使用标志、使用break退出循环、在循环中使用continue、避免无限循环
文章目录一.while循环简介二.使用while循环三.让用户选择何时退出四.使用标志五.使用break退出循环六.在循环中使用continue 七.避免无限循环一.while循环简介 ...
foxmail邮件加载失败重试_java retry(重试) spring retry, guava retrying 详解
系列说明 java retry 的一步步实现机制. java-retry 源码地址情景导入简单的需求产品经理:实现一个按条件,查询用户信息的服务. 小明:好的.没问题. 代码 UserServi ...

ThreadPoolExecutor中addWorker，continue retry和break retry是什么意思

ThreadPoolExecutor中addWorker，continue retry和break retry是什么意思相关推荐

最新文章

热门文章