Pasted

package ch.claude_martin.foo;
 
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ForkJoinPool;
 
public class MyClass {
 
    static class Car {
        private String owner = "N/A";
 
        public String getOwner() {
            return this.owner;
        }
 
        public void setOwner(String o) {
            this.owner = o;
        }
    }
 
    volatile Car car = null;
 
    public static void main(String args[]) throws InterruptedException {
        new MyClass().go();
    }
 
    void go() throws InterruptedException {
 
        ExecutorService es = ForkJoinPool.commonPool();
        Runnable taskA = () -> {
            car = null;
        };
 
        Runnable taskB = () -> {
            car = new Car();
            // we call yield() because it would be rather unlikely that the thread is
            // interrupted here. You can remove it, but it will take longer.
            Thread.yield();
            car.setOwner("Jane");
        };
 
        Runnable taskC = () -> {
            final Car copy = car; // taskA might set this to null at any time
            if (copy != null) {
                final String owner = copy.getOwner();
                if ("N/A".equals(owner)) {
                    System.err.println(owner);
                    System.exit(0);// Stop the VM because we got to read the initial value
                } 
                // else System.out.println(owner);
            }
        };
 
        while (true) {
            es.submit(taskA);
            es.submit(taskB);
            es.submit(taskC);
        }
    }
}