/*
 * Decompiled with CFR 0.152.
 * 
 * Could not load the following classes:
 *  com.ca.apim.gateway.extension.sharedstate.Configuration
 *  com.ca.apim.gateway.extension.sharedstate.Configuration$Param
 *  com.ca.apim.gateway.extension.sharedstate.SharedExecutorServiceProvider
 *  com.ca.apim.gateway.extension.sharedstate.SharedScheduledExecutorService
 */
package com.l7tech.server.extension.provider.sharedstate;

import com.ca.apim.gateway.extension.sharedstate.Configuration;
import com.ca.apim.gateway.extension.sharedstate.SharedExecutorServiceProvider;
import com.ca.apim.gateway.extension.sharedstate.SharedScheduledExecutorService;
import com.l7tech.server.extension.provider.sharedstate.LocalScheduledExecutorService;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

public class LocalExecutorServiceProvider
implements SharedExecutorServiceProvider {
    private final ConcurrentMap<String, SharedScheduledExecutorService> a = new ConcurrentHashMap<String, SharedScheduledExecutorService>();

    public SharedScheduledExecutorService getScheduledExecutorService(String string2, Configuration configuration) {
        return this.a.computeIfAbsent(string2, string -> new LocalScheduledExecutorService((String)string, Integer.parseInt(configuration.get(Configuration.Param.SCHEDULED_EXECUTOR_CORE_POOL_SIZE))));
    }
}