package ru.sql.java;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang.ArrayUtils;

public abstract class Digest {
    
    private Map<String, byte[]> cache = new HashMap<>(); // без volatile !!!

    public byte[] digest(String input) {
        byte[] result = cache.get(input);
        if (result == null) {
            synchronized (cache) {
                result = cache.get(input);
                if (result == null) {
                    result = doDigest(input);
                    cache.put(input, result);
                }
            }
        } else {
            // если key == value, тогда OK
            if (!ArrayUtils.isEquals(input.getBytes(), result)) {
                System.out.printf("%s != %d%n", input, result[0]); // FAIL, если get() выдал не то, что нужно
            }
        }
        return result;
    }

    protected abstract byte[] doDigest(String input);
    
    static long key = 0;

    public static void main(String[] args) {
        Digest digest = new Digest() {
            @Override
            protected byte[] doDigest(String input) {
                return input.getBytes();
            }
        };
        
        Runnable r = () -> digest.digest(String.valueOf(++key));
        
        List<Thread> tl;
        
        int times = 5000;
        
        // выполняется put() (т.к. cache еще пуст)
        
        key = 0;
        tl = new ArrayList<>();
        for (int i = 0; i < times; i++) {
            tl.add(new Thread(r));
        }
        for (Thread t: tl) {
            t.start();
        }
        
        // теперь get() возвращает неNULLевое значение
        
        key = 0;
        tl = new ArrayList<>();
        for (int i = 0; i < times; i++) {
            tl.add(new Thread(r));
        }
        for (Thread t: tl) {
            t.start();
        }
    }
}