原子/挥发/同步内部是如何工作的?

下面的代码块有什么区别?

代码1

private int counter;

public int getNextUniqueIndex() {
    return counter++; 
}

代码2

private AtomicInteger counter;

public int getNextUniqueIndex() {
    return counter.getAndIncrement();
}

代码3

private volatile int counter;

public int getNextUniqueIndex() {
    return counter++; 
}

挥发物以以下方式工作吗?是

volatile int i = 0;
void incIBy5() {
    i += 5;
}

相当于

Integer i = 5;
void incIBy5() {
    int temp;
    synchronized(i) { temp = i }
    synchronized(i) { i = temp + 5 }
}

我认为两个线程不能同时进入同步块…我说的对吗?如果这是真的,那么如何atomic.incrementAndGet()工作没有同步?它是否线程安全?

内部读取和写入volatile变量/原子变量之间的区别是什么?我在一些文章中读到,线程有一个变量的本地副本-那是什么?


当前回答

挥发性:

Volatile是一个关键字。Volatile强制所有线程从主存而不是缓存中获取变量的最新值。访问volatile变量不需要锁定。所有线程都可以同时访问volatile变量值。

使用易失性变量可以降低内存一致性错误的风险,因为对易失性变量的任何写入都会与该变量的后续读取建立happens-before关系。

这意味着对volatile变量的更改总是对其他线程可见。更重要的是,这也意味着当线程读取一个volatile变量时,它不仅看到了对volatile的最新更改,还看到了导致更改的代码的副作用。

何时使用:一个线程修改数据,其他线程必须读取数据的最新值。其他线程将采取一些操作,但它们不会更新数据。

原子XXX:

AtomicXXX类支持对单个变量进行无锁线程安全编程。这些AtomicXXX类(如AtomicInteger)解决了内存不一致错误/修改volatile变量的副作用,这些变量在多个线程中被访问。

何时使用:多个线程可以读取和修改数据。

同步:

Synchronized是用于保护方法或代码块的关键字。通过使方法同步有两个效果:

First, it is not possible for two invocations of synchronized methods on the same object to interleave. When one thread is executing a synchronized method for an object, all other threads that invoke synchronized methods for the same object block (suspend execution) until the first thread is done with the object. Second, when a synchronized method exits, it automatically establishes a happens-before relationship with any subsequent invocation of a synchronized method for the same object. This guarantees that changes to the state of the object are visible to all threads.

何时使用:多个线程可以读取和修改数据。您的业务逻辑不仅更新数据,还执行原子操作

AtomicXXX相当于volatile + synchronized,尽管实现不同。AmtomicXXX扩展了volatile变量+ compareAndSet方法,但不使用同步。

相关的SE问题:

Java中volatile和synchronized的区别

Volatile boolean vs AtomicBoolean

值得阅读的好文章:(以上内容摘自这些文档页面)

https://docs.oracle.com/javase/tutorial/essential/concurrency/sync.html

https://docs.oracle.com/javase/tutorial/essential/concurrency/atomic.html

https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/package-summary.html

其他回答

挥发性:

Volatile是一个关键字。Volatile强制所有线程从主存而不是缓存中获取变量的最新值。访问volatile变量不需要锁定。所有线程都可以同时访问volatile变量值。

使用易失性变量可以降低内存一致性错误的风险,因为对易失性变量的任何写入都会与该变量的后续读取建立happens-before关系。

这意味着对volatile变量的更改总是对其他线程可见。更重要的是,这也意味着当线程读取一个volatile变量时,它不仅看到了对volatile的最新更改,还看到了导致更改的代码的副作用。

何时使用:一个线程修改数据,其他线程必须读取数据的最新值。其他线程将采取一些操作,但它们不会更新数据。

原子XXX:

AtomicXXX类支持对单个变量进行无锁线程安全编程。这些AtomicXXX类(如AtomicInteger)解决了内存不一致错误/修改volatile变量的副作用,这些变量在多个线程中被访问。

何时使用:多个线程可以读取和修改数据。

同步:

Synchronized是用于保护方法或代码块的关键字。通过使方法同步有两个效果:

First, it is not possible for two invocations of synchronized methods on the same object to interleave. When one thread is executing a synchronized method for an object, all other threads that invoke synchronized methods for the same object block (suspend execution) until the first thread is done with the object. Second, when a synchronized method exits, it automatically establishes a happens-before relationship with any subsequent invocation of a synchronized method for the same object. This guarantees that changes to the state of the object are visible to all threads.

何时使用:多个线程可以读取和修改数据。您的业务逻辑不仅更新数据,还执行原子操作

AtomicXXX相当于volatile + synchronized,尽管实现不同。AmtomicXXX扩展了volatile变量+ compareAndSet方法,但不使用同步。

相关的SE问题:

Java中volatile和synchronized的区别

Volatile boolean vs AtomicBoolean

值得阅读的好文章:(以上内容摘自这些文档页面)

https://docs.oracle.com/javase/tutorial/essential/concurrency/sync.html

https://docs.oracle.com/javase/tutorial/essential/concurrency/atomic.html

https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/package-summary.html

将变量声明为volatile意味着修改其值立即影响变量的实际内存存储。编译器不能优化掉对变量的任何引用。这保证当一个线程修改变量时,所有其他线程立即看到新值。(对于非易失性变量,不能保证这一点。)

Declaring an atomic variable guarantees that operations made on the variable occur in an atomic fashion, i.e., that all of the substeps of the operation are completed within the thread they are executed and are not interrupted by other threads. For example, an increment-and-test operation requires the variable to be incremented and then compared to another value; an atomic operation guarantees that both of these steps will be completed as if they were a single indivisible/uninterruptible operation.

对一个变量的所有访问同步一次只允许一个线程访问该变量,并强制所有其他线程等待访问该变量的线程释放其对该变量的访问。

同步访问类似于原子访问,但是原子操作通常在较低的编程级别上实现。此外,完全可以只同步对变量的某些访问,而允许其他访问不同步(例如,同步对变量的所有写操作,但不同步从变量中读取操作)。

原子性、同步性和波动性是独立的属性,但通常结合使用,以加强访问变量时的适当线程合作。

附录(2016年4月)

对变量的同步访问通常使用监视器或信号量实现。这些是低级互斥(互斥)机制,允许线程独占地获得对变量或代码块的控制,如果其他线程也试图获得相同的互斥,则强制所有其他线程等待。一旦拥有这个互斥量的线程释放了这个互斥量,另一个线程就可以依次获得这个互斥量。

附录(2016年7月)

对象发生同步。这意味着调用类的同步方法将锁定调用的This对象。静态同步方法将锁定Class对象本身。

同样,进入同步块需要锁定方法的this对象。

这意味着同步方法(或块)可以同时在多个线程中执行,如果它们锁定在不同的对象上,但是对于任何给定的单个对象,一次只能有一个线程执行同步方法(或块)。

我知道两个线程不能同时进入同步块

两个线程不能两次进入同一个对象的同步块。这意味着两个线程可以在不同的对象上进入相同的块。这种混乱可能导致这样的代码。

private Integer i = 0;

synchronized(i) {
   i++;
}

这不会像预期的那样,因为它可能每次都锁定在不同的对象上。

如果这是真的,那么这个atomic.incrementAndGet()如何在没有同步的情况下工作??线程安全吗??

是的。它不使用锁来实现线程安全。

如果您想更详细地了解它们的工作原理,可以阅读它们的代码。

内部读取和写入Volatile变量/原子变量之间的区别是什么?

原子类使用volatile字段。在这个领域没有区别。区别在于所执行的操作。Atomic类使用CompareAndSwap或CAS操作。

我在一些文章中读到线程有变量的本地副本,那是什么?

我只能假设它指的是每个CPU都有自己的缓存内存视图,这可能与其他CPU不同。为了确保CPU拥有一致的数据视图,您需要使用线程安全技术。

这只在共享内存且至少有一个线程更新内存时才会出现问题。

volatile +同步是一个完全原子化的操作(语句)的可靠解决方案,它包含了对CPU的多条指令。

Say for eg:volatile int i = 2; i++, which is nothing but i = i + 1; which makes i as the value 3 in the memory after the execution of this statement. This includes reading the existing value from memory for i(which is 2), load into the CPU accumulator register and do with the calculation by increment the existing value with one(2 + 1 = 3 in accumulator) and then write back that incremented value back to the memory. These operations are not atomic enough though the value is of i is volatile. i being volatile guarantees only that a SINGLE read/write from memory is atomic and not with MULTIPLE. Hence, we need to have synchronized also around i++ to keep it to be fool proof atomic statement. Remember the fact that a statement includes multiple statements.

希望这个解释足够清楚。

你特别问了他们内部是如何运作的,所以你是这样的:

没有同步

private int counter;

public int getNextUniqueIndex() {
  return counter++; 
}

It basically reads value from memory, increments it and puts back to memory. This works in single thread but nowadays, in the era of multi-core, multi-CPU, multi-level caches it won't work correctly. First of all it introduces race condition (several threads can read the value at the same time), but also visibility problems. The value might only be stored in "local" CPU memory (some cache) and not be visible for other CPUs/cores (and thus - threads). This is why many refer to local copy of a variable in a thread. It is very unsafe. Consider this popular but broken thread-stopping code:

private boolean stopped;

public void run() {
    while(!stopped) {
        //do some work
    }
}

public void pleaseStop() {
    stopped = true;
}

将volatile添加到stopped变量中,它工作得很好——如果任何其他线程通过pleaseStop()方法修改了stopped变量,你可以保证在工作线程的while(!stopped)循环中立即看到该更改。顺便说一句,这也不是一个中断线程的好方法,参见:如何停止一个永远运行而没有任何用途的线程和停止一个特定的java线程。

AtomicInteger

private AtomicInteger counter = new AtomicInteger();

public int getNextUniqueIndex() {
  return counter.getAndIncrement();
}

AtomicInteger类使用CAS(比较和交换)底层CPU操作(不需要同步!)它们允许您仅在当前值等于其他值(并且成功返回)时修改特定变量。所以当你执行getAndIncrement()时,它实际上在循环中运行(简化的实际实现):

int current;
do {
  current = get();
} while(!compareAndSet(current, current + 1));

基本上就是:阅读;尝试储存增加的价值;如果不成功(该值不再等于current),请读取后重试。compareAndSet()是在本机代码(程序集)中实现的。

不同步的Volatile

private volatile int counter;

public int getNextUniqueIndex() {
  return counter++; 
}

这段代码不正确。它修复了可见性问题(volatile确保其他线程可以看到counter所做的更改),但仍然存在竞态条件。这已经解释了很多次:前/后增量不是原子的。

volatile的唯一副作用是“刷新”缓存,以便所有其他方都能看到最新版本的数据。这在大多数情况下都太严格了;这就是为什么volatile不是默认值。

不同步易变(2)

volatile int i = 0;
void incIBy5() {
  i += 5;
}

同样的问题,但更糟糕的是,因为i不是私有的。竞态条件仍然存在。为什么这是个问题?如果两个线程同时运行这段代码,那么输出可能是+ 5或+ 10。但是,您一定会看到变化。

多独立同步

void incIBy5() {
  int temp;
  synchronized(i) { temp = i }
  synchronized(i) { i = temp + 5 }
}

令人惊讶的是,这段代码也是不正确的。事实上,这是完全错误的。首先,你正在同步i,这是即将被改变的(此外,i是一个原语,所以我猜你正在同步一个通过自动装箱创建的临时整数…)完全有缺陷的。你也可以这样写:

synchronized(new Object()) {
  //thread-safe, SRSLy?
}

没有两个线程可以使用相同的锁进入相同的同步块。在这种情况下(在您的代码中也类似),锁对象在每次执行时都会改变,因此同步实际上没有任何影响。

即使您使用了最终变量(或this)进行同步,代码仍然是不正确的。两个线程可以首先同步地将i读入temp(在temp中有相同的本地值),然后第一个线程将一个新值赋给i(比如,从1到6),另一个线程做同样的事情(从1到6)。

同步必须从读取到赋值。第一次同步没有效果(读取int是原子的),第二次也是如此。在我看来,这些是正确的形式:

void synchronized incIBy5() {
  i += 5 
}

void incIBy5() {
  synchronized(this) {
    i += 5 
  }
}

void incIBy5() {
  synchronized(this) {
    int temp = i;
    i = temp + 5;
  }
}