Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Effectively Immutable Object

I want to make sure that I correctly understand the 'Effectively Immutable Objects' behavior according to Java Memory Model.

Let's say we have a mutable class which we want to publish as an effectively immutable:

class Outworld {
  // This MAY be accessed by multiple threads
  public static volatile MutableLong published;
}

// This class is mutable
class MutableLong {
  private long value;

  public MutableLong(long value) {
    this.value = value;
  }

  public void increment() {
    value++;
  }

  public long get() {
    return value;
  }
}

We do the following:

// Create a mutable object and modify it
MutableLong val = new MutableLong(1);
val.increment();
val.increment();
// No more modifications
// UPDATED: Let's say for this example we are completely sure
//          that no one will ever call increment() since now

// Publish it safely and consider Effectively Immutable
Outworld.published = val;

The question is: Does Java Memory Model guarantee that all threads MUST have Outworld.published.get() == 3 ?

According to Java Concurrency In Practice this should be true, but please correct me if I'm wrong.

3.5.3. Safe Publication Idioms

To publish an object safely, both the reference to the object and the object's state must be made visible to other threads at the same time. A properly constructed object can be safely published by:
- Initializing an object reference from a static initializer;
- Storing a reference to it into a volatile field or AtomicReference;
- Storing a reference to it into a final field of a properly constructed object; or
- Storing a reference to it into a field that is properly guarded by a lock.

3.5.4. Effectively Immutable Objects

Safely published effectively immutable objects can be used safely by any thread without additional synchronization.

like image 566
Vladimir Sorokin Avatar asked Apr 20 '12 22:04

Vladimir Sorokin


3 Answers

Yes. The write operations on the MutableLong are followed by a happens-before relationship (on the volatile) before the read.

(It is possible that a thread reads Outworld.published and passes it on to another thread unsafely. In theory, that could see earlier state. In practice, I don't see it happening.)

like image 89
Tom Hawtin - tackline Avatar answered Nov 16 '22 22:11

Tom Hawtin - tackline


There is a couple of conditions which must be met for the Java Memory Model to guarantee that Outworld.published.get() == 3:

  • the snippet of code you posted which creates and increments the MutableLong, then sets the Outworld.published field, must happen with visibility between the steps. One way to achieve this trivially is to have all that code running in a single thread - guaranteeing "as-if-serial semantics". I assume that's what you intended, but thought it worth pointing out.
  • reads of Outworld.published must have happens-after semantics from the assignment. An example of this could be having the same thread execute Outworld.published = val; then launch other the threads which could read the value. This would guarantee "as if serial" semantics, preventing re-ordering of the reads before the assignment.

If you are able to provide those guarantees, then the JMM will guarantee all threads see Outworld.published.get() == 3.


However, if you're interested in general program design advice in this area, read on.

For the guarantee that no other threads ever see a different value for Outworld.published.get(), you (the developer) have to guarantee that your program does not modify the value in any way. Either by subsequently executing Outworld.published = differentVal; or Outworld.published.increment();. While that is possible to guarantee, it can be so much easier if you design your code to avoid both the mutable object, and using a static non-final field as a global point of access for multiple threads:

  • instead of publishing MutableLong, copy the relevant values into a new instance of a different class, whose state cannot be modified. E.g.: introduce the class ImmutableLong, which assigns value to a final field on construction, and doesn't have an increment() method.
  • instead of multiple threads accessing a static non-final field, pass the object as a parameter to your Callable/Runnable implementations. This will prevent the possibility of one rogue thread from reassigning the value and interfering with the others, and is easier to reason about than static field reassignment. (Admittedly, if you're dealing with legacy code, this is easier said than done).
like image 5
Grundlefleck Avatar answered Nov 16 '22 22:11

Grundlefleck


The question is: Does Java Memory Model guarantee that all threads MUST have Outworld.published.get() == 3 ?

The short answer is no. Because other threads might access Outworld.published before it has been read.

After the moment when Outworld.published = val; had been performed, under condition that no other modifications done with the val - yes - it always be 3.

But if any thread performs val.increment then its value might be different for other threads.

like image 3
Eugene Retunsky Avatar answered Nov 17 '22 00:11

Eugene Retunsky