NoVisibility thread example

NoVisibility.java

import java.util.Random;
import java.util.concurrent.*;

class NoVisibility {

    private boolean ready;
    private int number;
    private final ExecutorService executor;
    private final Random random;

    NoVisibility(ExecutorService executor, Random random) {
        this.executor = executor;
        this.random = random;
    }

    private class Reader implements Callable<Integer> {
        @Override
        public Integer call() throws Exception {
            while (!ready) {
                Thread.yield();
            }
            return number;
        }
    }

    int go() throws ExecutionException, InterruptedException {
        Future<Integer> submission = executor.submit(new Reader());
        int randomNumber = random.nextInt();
        this.number = randomNumber;
        ready = true;
        return submission.get() - randomNumber;
    }
}