代码之家 › 专栏 › 技术社区 › rodrigoap

java.util.concurrent.ThreadPoolExecutor奇怪的逻辑

multithreading java

rodrigoap · 技术社区 · 16 年前

public void execute(Runnable command) {
    ...
        if (runState == RUNNING && workQueue.offer(command)) {
            if (runState != RUNNING || poolSize == 0)
                ensureQueuedTaskHandled(command);
        }
    ...
}

它检查一下 runState 是 RUNNING
你认为这个代码正确吗?

2 回复 | 直到 16 年前

Adamski 16 年前

执行器的运行状态可能会在初始检查和后续检查之间发生变化 将命令添加到队列后 shutdown() 方法被调用。

执行第二个检查,以便如果执行器已关闭,则任何排队的任务都会得到适当的处理,而不是滞留在队列中。

Alexander Pogrebnyak 16 年前

runState volatile ,所以在初始检查和调用 workQueue.offer

推荐文章

user29759326 · 如何返回递归函数中的最后一个值?

1 年前

malife89 · 将java中的字符串读取为正确的日期格式

1 年前

Tim · 在java中,有没有更快的方法将字节数组写入文件?

1 年前

pebble unit · 如何检查以前缀开头、以后缀结尾的属性(不是属性值)

1 年前

Nuñito Calzada · Spring Boot with JWT:访问此资源需要完全身份验证

1 年前

rudraraj · java中未声明最终变量

1 年前

Bala Ji · 以下BFS的实施效率如何?

1 年前

MineRickStar · 如何在Java中从Windows获取当前选定的应用程序

1 年前

user2649681 · 实时生成音频以写入“SourceDataLine”`

1 年前

davidalayachew · 为什么我的文件有竞争条件,即使我使用了StandardOpenOption。同步?

1 年前