contextualize.md

package com.netcracker.dstud.servicepackage.service.specification;

import java.util.concurrent.*;
import java.util.function.*;

public class M
{
    public static void main(String[] args)
    {
        ThreadLocal<Object> tl = new ThreadLocal<>();
        tl.set(1);
        CompletableFuture.supplyAsync(contextualize1(tl, tl.get())).thenApplyAsync(contextualize2(tl, tl.get()));
    }

    private static Supplier<Integer> contextualize1(ThreadLocal<Object> tl, Object precTlValue)
    {
        return () -> {
            Object o = tl.get();
            tl.set(precTlValue);
            try{
                int i = 2;
                return i;
            }
            finally
            {
                tl.set(o);;
            }
        };
    }

    private static Function<Integer, Integer> contextualize2(ThreadLocal<Object> tl, Object precTlValue)
    {
        return integer -> {
            Object o = tl.get();
            tl.set(precTlValue);
            try{
                int i = 3;
                return i;
            }
            finally
            {
                tl.set(o);;
            }
        };
    }
}