小编V16*_*666的帖子

AtomicInteger 和比较操作

我正在尝试使用 AtomicInteger 变量作为锁。因此,想知道下面发布的代码是否是线程安全的。我知道incrementAndGet()是一个原子操作。但是,我不确定后续的 '==' 操作是否也将是原子的(如果在我进行比较时该值增加到 2,该怎么办。)。所以发布这个问题来听听你的想法。

private AtomicInteger count = new AtomicInteger(0); //Shared variable
private final int max = 1;

if(count.incrementAndGet() == max) {
  //Do something
}
Run Code Online (Sandbox Code Playgroud)

java multithreading atomicinteger

5
推荐指数
1
解决办法
3819
查看次数

原子变量是否保证“在关系之前发生”?

我有一个要求,我需要在完成后发布“n”个线程的结果。为了检查所有线程是否已完成,我使用了 AtomicInteger (incrementAndGet()) 并将其值与最终变量进行比较。在进行检查之前,我将各个线程的结果写入共享对象(写入并发散列图,因为非同步数据结构 dint 似乎就足够了)。所以,我的问题是,在我的计数器通过“if”条件之前,所有线程是否会完成对共享对象的写入(并且主线程是否能够看到一致的内存)?

这是示例代码:

公共无效运行(){

    //Values is a concurrent hashMap. 
    values.put(Thread.currentThread().getName(), Thread.currentThread().getName());

    if(counter.incrementAndGet() == 5) {
        //Do something
    }
}
Run Code Online (Sandbox Code Playgroud)

java concurrency java-memory-model compare-and-swap

0
推荐指数
1
解决办法
751
查看次数